feat (MySQL): return rowcount on update

Author: chaen

src/DIRAC/Core/Utilities/MySQL.py

@@ -760,6 +760,7 @@ def _update(self, cmd, *, args=None, conn=None, debug=True):
 
         :return: S_OK with number of updated registers upon success.
                  S_ERROR upon error.
+                 lastRowId: if set, added to the returned dictionary
         """
 
         self.log.debug(f"_update: {self._safeCmd(cmd)}")
@@ -774,9 +775,11 @@ def _update(self, cmd, *, args=None, conn=None, debug=True):
         try:
             cursor = connection.cursor()
             res = cursor.execute(cmd, args=args)
+
             retDict = S_OK(res)
             if cursor.lastrowid:
                 retDict["lastRowId"] = cursor.lastrowid
+
         except Exception as x:
             retDict = self._except("_update", x, "Execution failed.", cmd, debug)
 

src/DIRAC/DataManagementSystem/Utilities/DMSHelpers.py

@@ -402,7 +402,7 @@ def getAllSEsInGroupAtSite(self, seGroup, site):
             return sesAtSite
         foundSEs = set(seList) & set(sesAtSite["Value"])
         if not foundSEs:
-            sLog.warn("No SE found at that site", f"in group {seGroup} at {site}")
+            sLog.verbose("No SE found at that site", f"in group {seGroup} at {site}")
             return S_OK()
         return S_OK(sorted(foundSEs))
 

src/DIRAC/DataManagementSystem/scripts/dirac_dms_protocol_matrix.py

@@ -177,7 +177,6 @@ def main():
     for src, dst in ((x, y) for x in fromSE for y in targetSE):
         if ftsTab:
             try:
-                # breakpoint()
                 fts3TpcProto = fts3Plugin.selectTPCProtocols(sourceSEName=ses[src].name, destSEName=ses[dst].name)
                 res = ses[dst].generateTransferURLsBetweenSEs(lfn, ses[src], fts3TpcProto)
             except ValueError as e: