From 202e1a73538b8844a1942171263e5c1507a1a7b3 Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Thu, 21 Jan 2021 16:11:32 +0100 Subject: [PATCH] Added node os path list. Signed-off-by: Cristiano Urban --- transfer_service/retrieve_preprocessor.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/transfer_service/retrieve_preprocessor.py b/transfer_service/retrieve_preprocessor.py index 2a30089..faaee7e 100644 --- a/transfer_service/retrieve_preprocessor.py +++ b/transfer_service/retrieve_preprocessor.py @@ -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): @@ -22,10 +23,11 @@ class RetrievePreprocessor(TaskExecutor): while True: self.wait() if self.destQueue.len() < self.maxReadyJobs and self.srcQueue.len() > 0: - self.jobObj = self.srcQueue.getJob() - - # do something here... - + self.jobObj = self.srcQueue.getJob() + 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 -- GitLab