diff --git a/src/python/AsyncStageOut/TransferWorker.py b/src/python/AsyncStageOut/TransferWorker.py index 9dfc425..06b7bef 100644 --- a/src/python/AsyncStageOut/TransferWorker.py +++ b/src/python/AsyncStageOut/TransferWorker.py @@ -301,7 +301,7 @@ def command(self, jobs, jobs_lfn, jobs_pfn, jobs_report): # Validate copyjob file before doing anything self.logger.debug("Valid %s" % self.validate_copyjob(copyjob)) if not self.validate_copyjob(copyjob): continue - rest_copyjob = '{"params":{"bring_online":null,"verify_checksum":false,"reuse":true,"copy_pin_lifetime":-1,"max_time_in_queue":20,"job_metadata":{"issuer": "ASO"},"spacetoken":null,"source_spacetoken":null,"fail_nearline":false,"overwrite":true,"gridftp":null},"files":[' + rest_copyjob = '{"params":{"bring_online":null,"verify_checksum":false,"reuse":false,"copy_pin_lifetime":-1,"max_time_in_queue":20,"job_metadata":{"issuer": "ASO"},"spacetoken":null,"source_spacetoken":null,"fail_nearline":false,"overwrite":true,"gridftp":null},"files":[' pairs = [] for SrcDest in copyjob: pairs.append('{"sources":["' + SrcDest.split(" ")[0] + '"],"metadata":null,"destinations":["' + SrcDest.split(" ")[1] + '"]}')