diff --git a/transfer_service/retrieve_preprocessor.py b/transfer_service/retrieve_preprocessor.py index 0165d68d7074ba6f32c5c9fdf29ba3c45b2fbc97..57126e9eb8b70fad56eb93c07fdc3295202091a6 100644 --- a/transfer_service/retrieve_preprocessor.py +++ b/transfer_service/retrieve_preprocessor.py @@ -43,9 +43,13 @@ class RetrievePreprocessor(TaskExecutor): super(RetrievePreprocessor, self).__init__() def execute(self): - vospacePathList = self.jobObj.jobInfo["transfer"]["target"] - for vospacePath in vospacePathList: - self.nodeList.append(vospacePath.split("!vospace")[1]) + target = self.jobObj.jobInfo["transfer"]["target"].split("!vospace")[1] + params = self.jobObj.jobInfo["transfer"]["view"]["param"] + if not params: + self.nodeList.append(target) + else: + for el in params: + self.nodeList.append(target + '/' + el["value"]) self.jobObj.jobInfo["nodeList"] = self.nodeList.copy() def update(self):