Loading transfer_service/store_executor.py +2 −0 Original line number Diff line number Diff line Loading @@ -69,6 +69,8 @@ class StoreExecutor(TaskExecutor): def update(self): self.dbConn.connect() out = open("store_executor_log.txt", "a") results = [{"target": ""}] self.dbConn.setResults(self.jobId, results) for nodeVOSPath in self.nodeList: out.write(f"nodeListElement: {nodeVOSPath}\n") self.dbConn.setAsyncTrans(nodeVOSPath, True); Loading Loading
transfer_service/store_executor.py +2 −0 Original line number Diff line number Diff line Loading @@ -69,6 +69,8 @@ class StoreExecutor(TaskExecutor): def update(self): self.dbConn.connect() out = open("store_executor_log.txt", "a") results = [{"target": ""}] self.dbConn.setResults(self.jobId, results) for nodeVOSPath in self.nodeList: out.write(f"nodeListElement: {nodeVOSPath}\n") self.dbConn.setAsyncTrans(nodeVOSPath, True); Loading