lib/cronicle/client.rb in cronicle-0.1.2 vs lib/cronicle/client.rb in cronicle-0.1.3

@@ -23,9 +23,13 @@
     if jobs_by_host.empty?
       raise "Definition cannot be found: Job `#{name}`"
     end
 
     parallel_each(jobs_by_host) do |host, jobs_by_user|
+      if @options[:ssh_user] and host !~ /@/
+        host = @options[:ssh_user] + '@' + host
+      end
+
       run_driver(host) do |driver|
         jobs_by_user.each do |user, jobs|
           driver.execute_job(user, jobs)
         end
       end