lib/rbbt/workflow/util/archive.rb in rbbt-util-5.26.89 vs lib/rbbt/workflow/util/archive.rb in rbbt-util-5.26.91

@@ -1,5 +1,6 @@
+require 'rbbt/workflow/remote/ssh/driver'
 class Step
   def self.link_job(path, target_dir, task = nil, workflow = nil)
     Path.setup(target_dir)
 
     name = File.basename(path)
@@ -122,11 +123,11 @@
 
     other_rsync_args = options[:rsync]
     relocate = options[:relocate]
 
     paths = if options[:source]
-              SSHClient.run(options[:source], <<-EOF).split("\n")
+              SSHDriver.run(options[:source], <<-EOF).split("\n")
 require 'rbbt-util'
 require 'rbbt/workflow'
 
 path = "#{path}"
 relocate = #{ relocate.to_s }
@@ -153,10 +154,10 @@
               end
               files
             end
 
     target = if options[:target] 
-               target = SSHClient.run(options[:target], <<-EOF).split("\n").first
+               target = SSHDriver.run(options[:target], <<-EOF).split("\n").first
 require 'rbbt-util'
 path = "var/jobs"
 resource = #{resource.to_s}
 search_path = "#{search_path}"
 puts resource[path].find(search_path)