From 88f5453b2ee2504dcee2b0d02f58bff22df9ca6f Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Fri, 28 May 2021 11:43:25 +0200 Subject: [PATCH] Set async_trans flag directly within insert operation. Signed-off-by: Cristiano Urban --- transfer_service/import_executor.py | 4 ++-- transfer_service/node.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/transfer_service/import_executor.py b/transfer_service/import_executor.py index f57db79..4f5a58f 100644 --- a/transfer_service/import_executor.py +++ b/transfer_service/import_executor.py @@ -90,10 +90,10 @@ class ImportExecutor(TaskExecutor): cnode.setLocationId(locationId) cnode.setCreatorID(self.userId) cnode.setContentLength(0) + cnode.setAsyncTrans(True) cnode.setSticky(True) if self.dbConn.insertNode(cnode): - self.dbConn.setAsyncTrans(vospacePath, True) now = dt.now() nodeList.append([ now, dir, vospacePath, "container", "DONE" ]) else: @@ -127,10 +127,10 @@ class ImportExecutor(TaskExecutor): dnode.setCreatorID(self.userId) dnode.setContentLength(os.path.getsize(file)) dnode.setContentMD5(self.md5calc.getMD5(file)) + dnode.setAsyncTrans(True) dnode.setSticky(True) if self.dbConn.insertNode(dnode): - self.dbConn.setAsyncTrans(vospacePath, True) now = dt.now() nodeList.append([ now, file, vospacePath, "data", "DONE" ]) else: diff --git a/transfer_service/node.py b/transfer_service/node.py index b782173..106e0bf 100644 --- a/transfer_service/node.py +++ b/transfer_service/node.py @@ -14,7 +14,7 @@ class Node(object): self.type = type self.locationId = None self.format = None - self.asyncTrans = None + self.asyncTrans = False self.sticky = False self.busyState = None self.creatorID = None -- GitLab