From ad07384eae6b56f64c30f95dcd94f52056440042 Mon Sep 17 00:00:00 2001 From: Simon Fayer Date: Thu, 7 May 2026 11:42:37 +0100 Subject: [PATCH] fix: Use existing connection for a few places it was missed in FileManager --- .../DB/FileCatalogComponents/FileManager/FileManager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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