Commit 449a32fa authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Changed the way we build the VOSpace node list. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban.slack@gmail.com>
parent b97a5034

transfer_service/retrieve_preprocessor.py

+7 −3
Original line number Diff line number Diff line
@@ -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):