fix: JobState does not need to push JobParameters

DIRACGrid · Jul 5, 2024 · c89eda9 · c89eda9
1 parent c3810d0
commit c89eda9
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/src/DIRAC/WorkloadManagementSystem/Client/JobState/JobState.py b/src/DIRAC/WorkloadManagementSystem/Client/JobState/JobState.py
@@ -5,7 +5,6 @@
 from DIRAC.WorkloadManagementSystem.Client.JobState.JobManifest import JobManifest
 from DIRAC.WorkloadManagementSystem.DB.JobDB import JobDB
 from DIRAC.WorkloadManagementSystem.DB.JobLoggingDB import JobLoggingDB
-from DIRAC.WorkloadManagementSystem.DB.JobParametersDB import JobParametersDB
 from DIRAC.WorkloadManagementSystem.DB.TaskQueueDB import TaskQueueDB, multiValueDefFields, singleValueDefFields
 from DIRAC.WorkloadManagementSystem.Service.JobPolicy import (
     RIGHT_CHANGE_STATUS,
@@ -26,7 +25,6 @@ def reset(self):
             self.jobDB = None
             self.logDB = None
             self.tqDB = None
-            self.jobParametersDB = None
 
     __db = DBHold()
 
@@ -38,7 +36,6 @@ def checkDBAccess(cls):
             JobState.__db.jobDB = JobDB()
             JobState.__db.logDB = JobLoggingDB()
             JobState.__db.tqDB = TaskQueueDB()
-            JobState.__db.jpDB = JobParametersDB()
 
     def __init__(self, jid):
         self.__jid = jid
@@ -103,7 +100,7 @@ def commitCache(self, initialState, cache, jobLog):
             return S_OK(False)
         gLogger.verbose(f"Job {self.__jid}: About to execute trace. Current state {initialState}")
 
-        data = {"att": [], "jobp": [], "optp": []}
+        data = {"att": [], "optp": []}
         for key in cache:
             for dk in data:
                 if key.find(f"{dk}.") == 0:
@@ -118,11 +115,6 @@ def commitCache(self, initialState, cache, jobLog):
             if not result["OK"]:
                 return result
 
-        if data["jobp"]:
-            result = self.__retryFunction(5, JobState.__db.jpDB.setJobParameters, (self.__jid, data["jobp"]))
-            if not result["OK"]:
-                return result
-
         for k, v in data["optp"]:
             result = self.__retryFunction(5, JobState.__db.jobDB.setJobOptParameter, (self.__jid, k, v))
             if not result["OK"]: