fix: StalledJobAgent talks directly to PilotAgentsDB

Author: fstagni

src/DIRAC/WorkloadManagementSystem/Agent/StalledJobAgent.py

@@ -518,8 +518,7 @@ def _checkLoggingInfo(self, jobID, jobDict):
         return startTime, endTime
 
     def _kickStuckJobs(self):
-        """Reschedule jobs stuck in initialization status Rescheduled,
-        Matched."""
+        """Reschedule jobs stuck in initialization status Rescheduled, Matched."""
 
         message = ""
 
@@ -550,7 +549,7 @@ def _kickStuckJobs(self):
 
         jobIDs = result["Value"]
         if jobIDs:
-            self.log.info(f"Rescheduling {len(jobIDs)} jobs stuck in Rescheduled status")
+            self.log.info(f"Rescheduling {len(jobIDs)} jobs stuck in {JobStatus.RESCHEDULED} status")
             result = jobManagerClient.rescheduleJob(jobIDs)
             if not result["OK"]:
                 message = f"Failed to reschedule jobs stuck in {JobStatus.RESCHEDULED} status"

src/DIRAC/WorkloadManagementSystem/Service/JobMonitoringHandler.py

@@ -276,7 +276,7 @@ def export_getJobParameters(self, jobIDs, parName=None):
                 return res
             parameters = res["Value"]
         else:  # a service is connecting, no proxy, e.g. StalledJobAgent
-            q = "SELECT JobID, VO FROM Jobs WHERE JobID IN (%s)" % ",".join([str(jobID) for jobID in jobIDs])
+            q = f"SELECT JobID, VO FROM Jobs WHERE JobID IN ({','.join([str(jobID) for jobID in jobIDs])})"
             res = self.jobDB._query(q)
             if not res["OK"]:
                 return res