diff --git a/iceprod/server/data/condor_transfer_plugins/gsiftp.py b/iceprod/server/data/condor_transfer_plugins/gsiftp.py index f2b1045e..aa2c9d73 100644 --- a/iceprod/server/data/condor_transfer_plugins/gsiftp.py +++ b/iceprod/server/data/condor_transfer_plugins/gsiftp.py @@ -123,6 +123,7 @@ def _do_transfer(self, inpath, outpath): '/cvmfs/icecube.opensciencegrid.org/iceprod/v2.7.1/env-shell.sh', 'globus-url-copy', '-cd', + '-rst', inpath, outpath, ], stderr=subprocess.STDOUT) diff --git a/iceprod/server/plugins/condor.py b/iceprod/server/plugins/condor.py index e06e7706..43782c84 100644 --- a/iceprod/server/plugins/condor.py +++ b/iceprod/server/plugins/condor.py @@ -253,7 +253,7 @@ async def submit(self, tasks: list[Task], jel: Path): log = {jel} notification = never -job_ad_information_attrs = Iwd IceProdDatasetId IceProdTaskId IceProdTaskInstanceId CommittedTime RemotePool RemoteMachine +job_ad_information_attrs = Iwd IceProdDatasetId IceProdTaskId IceProdTaskInstanceId CommittedTime RemotePool RemoteHost MATCH_EXP_JOBGLIDEIN_ResourceName batch_name = Dataset {tasks[0].dataset.dataset_num} +IsIceProdJob = True