Commit 202e1a73 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added node os path list. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent 9803b7ca

transfer_service/retrieve_preprocessor.py

+6 −4
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ class RetrievePreprocessor(TaskExecutor): 
                                  self.params["host"],

                                  self.params.getint("port"),

                                  self.params["db"])

        self.nodeList = []

        super(RetrievePreprocessor, self).__init__()



    def run(self):
@@ -23,9 +24,10 @@ class RetrievePreprocessor(TaskExecutor): 
            self.wait()

            if self.destQueue.len() < self.maxReadyJobs and self.srcQueue.len() > 0:

                self.jobObj = self.srcQueue.getJob()

                

                # do something here...

                

                vospacePath = self.jobObj.jobInfo["transfer"]["target"].split("!vospace")[1]

                osPath = dbConn.getOSPath(vospacePath)

                self.nodeList.append(osPath)

                self.jobObj.jobInfo["transfer"]["nodeList"] = self.nodeList

                self.srcQueue.extractJob()

                self.destQueue.insertJob(self.jobObj)

                print(f"Job {self.jobObj.jobId} MOVED from {self.srcQueue.name()} to {self.destQueue.name()}")
 
 No newline at end of file