fix: do not add JobStatus to JobParameters

fstagni · Jun 27, 2024 · c9336a7 · c9336a7
1 parent 8e98e80
commit c9336a7
Showing 1 changed file with 1 addition and 12 deletions.
diff --git a/src/DIRAC/WorkloadManagementSystem/Utilities/JobStatusUtility.py b/src/DIRAC/WorkloadManagementSystem/Utilities/JobStatusUtility.py
@@ -11,7 +11,6 @@
 from DIRAC.WorkloadManagementSystem.Client import JobStatus
 
 if TYPE_CHECKING:
-    from DIRAC.WorkloadManagementSystem.DB.JobParametersDB import JobParametersDB
     from DIRAC.WorkloadManagementSystem.DB.JobDB import JobDB
     from DIRAC.WorkloadManagementSystem.DB.JobLoggingDB import JobLoggingDB
 
@@ -21,7 +20,6 @@ def __init__(
         self,
         jobDB: JobDB = None,
         jobLoggingDB: JobLoggingDB = None,
-        elasticJobParametersDB: JobParametersDB = None,
     ) -> None:
         """
         :raises: RuntimeError, AttributeError
@@ -31,7 +29,6 @@ def __init__(
 
         self.jobDB = jobDB
         self.jobLoggingDB = jobLoggingDB
-        self.elasticJobParametersDB = elasticJobParametersDB
 
         if not self.jobDB:
             try:
@@ -53,11 +50,6 @@ def __init__(
                 self.log.error("Can't connect to the JobLoggingDB")
                 raise
 
-        if not self.elasticJobParametersDB:
-            result = ObjectLoader().loadObject("WorkloadManagementSystem.DB.JobParametersDB", "JobParametersDB")
-            if not result["OK"]:
-                raise AttributeError(result["Message"])
-            self.elasticJobParametersDB = result["Value"](parentLogger=self.log)
 
     def setJobStatus(
         self, jobID: int, status=None, minorStatus=None, appStatus=None, source=None, dateTime=None, force=False
@@ -154,10 +146,7 @@ def setJobStatusBulk(self, jobID: int, statusDict: dict, force: bool = False):
             result = self.jobDB.setJobAttributes(jobID, attrNames, attrValues, update=True, force=True)
             if not result["OK"]:
                 return result
-            if self.elasticJobParametersDB:
-                result = self.elasticJobParametersDB.setJobParameter(int(jobID), "Status", status)
-                if not result["OK"]:
-                    return result
+
         # Update start and end time if needed
         if not endTime and newEndTime:
             log.debug("Set job end time", endTime)