From 5f6a140ef1ee7e1a44c65c54671a8e7165f2f23b Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Thu, 22 Apr 2021 19:11:11 +0200 Subject: [PATCH] Added 'cleanup()' method to clear the node list at the end of the operations. Signed-off-by: Cristiano Urban --- transfer_service/retrieve_preprocessor.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/transfer_service/retrieve_preprocessor.py b/transfer_service/retrieve_preprocessor.py index 9c33732..aabfed7 100644 --- a/transfer_service/retrieve_preprocessor.py +++ b/transfer_service/retrieve_preprocessor.py @@ -30,6 +30,9 @@ class RetrievePreprocessor(TaskExecutor): self.nodeList = self.dbConn.getVOSpacePathList(vospacePath) self.jobObj.jobInfo["nodeList"] = self.nodeList + def cleanup(self): + self.nodeList.clear() + def run(self): print("Starting retrieve preprocessor...") self.setSourceQueueName("read_pending") @@ -41,4 +44,5 @@ class RetrievePreprocessor(TaskExecutor): self.execute() self.destQueue.insertJob(self.jobObj) self.srcQueue.extractJob() + self.cleanup() print(f"Job {self.jobObj.jobId} MOVED from {self.srcQueue.name()} to {self.destQueue.name()}") -- GitLab