diff --git a/transfer_service/retrieve_executor.py b/transfer_service/retrieve_executor.py index 21f5546d2b721e2849208fd7be8e6c0c81d50dd7..b8552314242e78d4d4623b935d5ce033b6f09cf1 100644 --- a/transfer_service/retrieve_executor.py +++ b/transfer_service/retrieve_executor.py @@ -343,24 +343,24 @@ class RetrieveExecutor(TaskExecutor): self.jobObj.setResults(results) + # Add a list of physical destination paths for each VOSpace node in the node list + self.logger.info("Generating physical destination paths for VOSpace nodes...") + for vospacePath in self.nodeList: + nodeInfo = self.dbConn.getOSPath(vospacePath) + baseSrcPath = nodeInfo["baseSrcPath"] + username = nodeInfo["username"] + srcPath = nodeInfo["fullPath"] + baseDestPath = self.storageRetrievePath.replace("{username}", username) + destPath = srcPath.replace(baseSrcPath, baseDestPath) + self.destPathList.append(destPath) + self.jobObj.jobInfo["destPathList"] = self.destPathList.copy() + if status == ("OK"): self.jobObj.setPhase("COMPLETED") self.jobObj.setEndTime(datetime.datetime.now().isoformat()) self.dbConn.insertJob(self.jobObj) self.logger.info("Job phase updated to COMPLETED.") - # Add a list of physical destination paths for each VOSpace node in the node list - self.logger.info("Generating physical destination paths for VOSpace nodes...") - for vospacePath in self.nodeList: - nodeInfo = self.dbConn.getOSPath(vospacePath) - baseSrcPath = nodeInfo["baseSrcPath"] - username = nodeInfo["username"] - srcPath = nodeInfo["fullPath"] - baseDestPath = self.storageRetrievePath.replace("{username}", username) - destPath = srcPath.replace(baseSrcPath, baseDestPath) - self.destPathList.append(destPath) - self.jobObj.jobInfo["destPathList"] = self.destPathList.copy() - msg = f""" ########## VOSpace data retrieval procedure summary ##########