diff --git a/Appl/CEP/CS1/CS1_pp_lib/scripts/CS1_Offline_pipeline_control.py b/Appl/CEP/CS1/CS1_pp_lib/scripts/CS1_Offline_pipeline_control.py index a3e8e8e8caeea9118d74df3b2010f17d2edf6901..eddf60f065343a3bb33c658c922a6a9129f5f41d 100644 --- a/Appl/CEP/CS1/CS1_pp_lib/scripts/CS1_Offline_pipeline_control.py +++ b/Appl/CEP/CS1/CS1_pp_lib/scripts/CS1_Offline_pipeline_control.py @@ -51,10 +51,16 @@ def spawn(dest, src, log): '/CS1_Offline_pipeline_node.py') ##Run the node script on every node ## os.system('ssh -A -t ' + dest[0] + ' "cd /local/renting;time >> pipeline.log"') - os.system('ssh -A -t ' + dest[0] + ' "setenv PYTHONPATH /app/LOFAR/stable;' + - 'source /app/scripts/doStableAIPS++; cd '+ dest[1] + ';python ' + - 'CS1_Offline_pipeline_node.py -r' + src[0] + ' -m' + src[1] + ' -d' + dest[0] + - ' -l' + log + ' >> pipeline.log"') + if src[0]: + os.system('ssh -A -t ' + dest[0] + ' "setenv PYTHONPATH /app/LOFAR/stable;' + + 'source /app/scripts/doStableAIPS++; cd '+ dest[1] + ';python ' + + 'CS1_Offline_pipeline_node.py -r' + src[0] + ' -m' + src[1] + ' -d' + dest[0] + + ' -l' + log + ' >> pipeline.log"') + else: + os.system('ssh -A -t ' + dest[0] + ' "setenv PYTHONPATH /app/LOFAR/stable;' + + 'source /app/scripts/doStableAIPS++; cd '+ dest[1] + ';python ' + + 'CS1_Offline_pipeline_node.py -m' + src[1] + ' -d' + dest[0] + + ' -l' + log + ' >> pipeline.log"') ## bash version for Pandey ## os.system('ssh -A -t ' + dest[0] + ' "export PYTHONPATH=/app/LOFAR/stable;' + ## '. /app/aips++/Unstable/aipsinit.sh; cd '+ dest[1] + ';python ' +