diff --git a/transfer_service/import_executor.py b/transfer_service/import_executor.py
index f57db79efaaec211300429c293b76302337a70b3..4f5a58f37bb0e73c2a534eb5882e220c979be6f0 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 b7821730ecdd79ef90f042eaf94dab66e2a6f486..106e0bfab7770799b8a9b3fefa71fac6c81a5d23 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