Loading transfer_service/store_executor.py +1 −1 Original line number Diff line number Diff line Loading @@ -135,7 +135,7 @@ class StoreExecutor(TaskExecutor): """ if len(self.nodeList) <= 10 ** 5: m.setMessageWithAttachment("VOSpace data storage notification: job COMPLETED", msg, nodeListFile) m.setMessageWithAttachment("VOSpace data storage notification: Job COMPLETED", msg, nodeListFile) else: info = f""" INFO: Loading transfer_service/store_preprocessor.py +1 −1 Original line number Diff line number Diff line Loading @@ -258,7 +258,7 @@ class StorePreprocessor(TaskExecutor): self.jobObj = self.srcQueue.getJob() self.jobId = self.jobObj.jobId self.storageId = self.jobObj.jobInfo["storageId"] self.storgeType = self.jobObj.jobInfo["storageType"] self.storageType = self.jobObj.jobInfo["storageType"] self.username = self.jobObj.jobInfo["userName"] self.prepare(self.username) self.execute() Loading Loading
transfer_service/store_executor.py +1 −1 Original line number Diff line number Diff line Loading @@ -135,7 +135,7 @@ class StoreExecutor(TaskExecutor): """ if len(self.nodeList) <= 10 ** 5: m.setMessageWithAttachment("VOSpace data storage notification: job COMPLETED", msg, nodeListFile) m.setMessageWithAttachment("VOSpace data storage notification: Job COMPLETED", msg, nodeListFile) else: info = f""" INFO: Loading
transfer_service/store_preprocessor.py +1 −1 Original line number Diff line number Diff line Loading @@ -258,7 +258,7 @@ class StorePreprocessor(TaskExecutor): self.jobObj = self.srcQueue.getJob() self.jobId = self.jobObj.jobId self.storageId = self.jobObj.jobInfo["storageId"] self.storgeType = self.jobObj.jobInfo["storageType"] self.storageType = self.jobObj.jobInfo["storageType"] self.username = self.jobObj.jobInfo["userName"] self.prepare(self.username) self.execute() Loading