Commit a12a6338 authored by Carl-Johan Haster's avatar Carl-Johan Haster
Browse files

add transfer of files in BW jobs

parent 6e00ec56
Pipeline #74005 passed with stages
in 71 minutes and 7 seconds
......@@ -2317,8 +2317,8 @@ class EngineJob(SingularityJob,pipeline.CondorDAGJob,pipeline.AnalysisJob):
pipeline.AnalysisJob.__init__(self,cp,dax=dax)
SingularityJob.__init__(self, cp)
# locations for file IO
self.add_condor_cmd('transfer_input_files','caches,engine,$(macroinput)')
self.add_condor_cmd('transfer_output_files','engine')
self.add_condor_cmd('transfer_input_files','caches,engine,ROQdata,$(macroinput)')
self.add_condor_cmd('transfer_output_files','engine,ROQdata,$(macrooutput)')
try:
hostname=socket.gethostbyaddr(socket.gethostname())[0]
......@@ -2725,6 +2725,8 @@ class BayesWavePSDJob(SingularityJob,pipeline.CondorDAGJob,pipeline.AnalysisJob)
self.add_condor_cmd('+CheckpointSig', 130)
self.add_condor_cmd('should_transfer_files', 'YES')
self.add_condor_cmd('when_to_transfer_output', 'ON_EXIT_OR_EVICT')
self.add_condor_cmd('transfer_input_files','caches,$(macroinput)')
self.add_condor_cmd('transfer_output_files','ROQdata')
......@@ -2767,6 +2769,8 @@ class BayesWavePostJob(SingularityJob,pipeline.CondorDAGJob,pipeline.AnalysisJob
self.add_condor_cmd('+CheckpointSig', 130)
self.add_condor_cmd('should_transfer_files', 'YES')
self.add_condor_cmd('when_to_transfer_output', 'ON_EXIT')
self.add_condor_cmd('transfer_input_files','ROQdata')
self.add_condor_cmd('transfer_output_files','ROQdata,$(macrooutput)')
class BayesWavePostNode(EngineNode):
def __init__(self,bayeswavepost_job):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment