share/rbbt_commands/lsf/task in rbbt-util-5.34.27 vs share/rbbt_commands/lsf/task in rbbt-util-5.35.1
- old
+ new
@@ -1,13 +1,16 @@
#!/usr/bin/env ruby
require 'rbbt/util/simpleopt'
require 'rbbt/workflow'
require 'rbbt/workflow/usage'
+require 'rbbt/workflow/remote_workflow'
require 'rbbt/hpc'
require 'time'
+rbbt_options = SOPT::GOT_OPTIONS
+
$slurm_options = SOPT.get <<EOF
-dr--dry_run Print only the template
-cj--clean_job Clean job
--drbbt* Use development version of rbbt
-sing--singularity Use Singularity
@@ -54,14 +57,22 @@
if done?
self.load
else
begin
Log.debug "Issuing SLURM job for #{self.path}"
- HPC::BATCH_MODULE.run_job(self, SOPT::GOT_OPTIONS.merge($slurm_options))
+ HPC::BATCH_MODULE.run_job(self, $slurm_options)
rescue HPC::SBATCH
end
end
end
end
-ARGV.concat ["-W", $slurm_options[:workflows]] if $slurm_options[:workflows]
+module RemoteStep::SSH
+
+ def _run
+ RemoteWorkflow::SSH.run_slurm_job(File.join(base_url, task.to_s), @input_id, @base_name, $slurm_options)
+ end
+
+end
+
+SOPT.current_options = rbbt_options
load Rbbt.share.rbbt_commands.workflow.task.find