diff --git a/src/DIRAC/DataManagementSystem/DB/FileCatalogComponents/FileManager/FileManager.py b/src/DIRAC/DataManagementSystem/DB/FileCatalogComponents/FileManager/FileManager.py
index c2ec3e42b3f..f920c624bce 100755
--- a/src/DIRAC/DataManagementSystem/DB/FileCatalogComponents/FileManager/FileManager.py
+++ b/src/DIRAC/DataManagementSystem/DB/FileCatalogComponents/FileManager/FileManager.py
@@ -298,7 +298,7 @@ def _insertFiles(self, lfns, uid, gid, connection=False):
         if insertTuples:
             fields = "FileID,GUID,Checksum,ChecksumType,CreationDate,ModificationDate,Mode"
             req = f"INSERT INTO FC_FileInfo ({fields}) VALUES {','.join(insertTuples)}"
-            res = self.db._update(req)
+            res = self.db._update(req, conn=connection)
             if not res["OK"]:
                 self._deleteFiles(toDelete, connection=connection)
                 for lfn in list(lfns):
@@ -841,7 +841,7 @@ def repairFileTables(self, connection=False):
 
         fields = "FileID,GUID,CreationDate,ModificationDate,Mode"
         req = f"INSERT INTO FC_FileInfo ({fields}) VALUES {','.join(insertTuples)}"
-        result = self.db._update(req)
+        result = self.db._update(req, conn=connection)
         if not result["OK"]:
             return result