minor osg workflow change to allow recovery of in-progress data

BayesWaveUtils/bayeswave_pipe/bayeswave_pipe_utils.py

@@ -971,7 +971,7 @@ def condor_job_config(job_type, condor_job, config_parser):
             # "Delayed Transfers" (strongly discouraged)
             # condor_job.add_condor_cmd('+WantCheckpointSignal', True)
             # condor_job.add_condor_cmd('+CheckpointSig', '"SIGINT"')
-            # condor_job.add_condor_cmd('when_to_transfer_output', 'ON_EXIT_OR_EVICT')
+            condor_job.add_condor_cmd('when_to_transfer_output', 'ON_EXIT_OR_EVICT')
         else:
             condor_job.add_condor_cmd('when_to_transfer_output', 'ON_EXIT')
 
@@ -998,7 +998,10 @@ def condor_job_config(job_type, condor_job, config_parser):
         # --- Force downstream jobs to run locally
         if job_type in ['bayeswave_post', 'bayeswave_fpeak', 'bayeswave_clean_frame',
                          'megaplot.py', 'megasky.py']:
-            requires.append("(GLIDEIN_SITE=?=undefined)")
+            #requires.append("(GLIDEIN_SITE=?=undefined)")
+            condor_job.add_condor_cmd('+flock_local', 'True')
+            condor_job.add_condor_cmd('+DESIRED_Sites', '\"nogrid\"')
+
         else:
             try:
                 condor_job.add_condor_cmd('+DESIRED_Sites',