attempt to switch to ElasticSearch methods

src/DIRAC/WorkloadManagementSystem/Agent/ScoutingJobStatusAgent.py

@@ -5,6 +5,7 @@
 from DIRAC.Core.Base.AgentModule import AgentModule
 from DIRAC.WorkloadManagementSystem.Client import JobStatus
 from DIRAC.ConfigurationSystem.Client.Helpers.Operations import Operations
+from DIRAC.WorkloadManagementSystem.Client.JobMonitoringClient import JobMonitoringClient
 from DIRAC.WorkloadManagementSystem.Client.JobStateUpdateClient import JobStateUpdateClient
 from DIRAC.WorkloadManagementSystem.DB.JobLoggingDB import JobLoggingDB
 
@@ -20,15 +21,17 @@ def __init__(self, *args, **kwargs):
         """
         AgentModule.__init__(self, *args, **kwargs)
 
-        self.jobDB = None
+        self.jobMonitor = None
+        self.jobUpdate = None
         self.logDB = None
 
   #############################################################################
     def initialize(self):
         """Sets defaults
         """
 
-        self.jobDB = JobStateUpdateClient()
+        self.jobMonitor = JobMonitoringClient()
+        self.jobUpdate = JobStateUpdateClient()
         self.logDB = JobLoggingDB()
 
         return S_OK()
@@ -62,7 +65,7 @@ def beginExecution(self):
     def execute(self):
         """The ScoutingJobStatus execution method.
         """
-        result = self.jobDB.selectJobs({'Status': 'Scouting'})
+        result = self.jobMonitor.getJobs({'Status': 'Scouting'})
         if not result['OK']:
             return result
 

src/DIRAC/WorkloadManagementSystem/Executor/Scouting.py

@@ -115,7 +115,6 @@ def __setScoutingStatus(self, jobState=None):
         if not jobState:
             jobState = self.__jobData.jobState
 
-        result = jobState.getStatus()
         if not (result := jobState.getStatus())['OK']:
             return result