From 1dfc7a5d876798af1d5954e33fa8840e011b9445 Mon Sep 17 00:00:00 2001 From: Andre Sailer Date: Fri, 2 Feb 2024 08:38:19 +0100 Subject: [PATCH] =?UTF-8?q?sweep:=20#7435=20fix(JobDB):=20getJobParameters?= =?UTF-8?q?=20and=20getJobsAttributes=20use=20integer=20jobIDs=E2=80=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/DIRAC/WorkloadManagementSystem/DB/JobDB.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/DIRAC/WorkloadManagementSystem/DB/JobDB.py b/src/DIRAC/WorkloadManagementSystem/DB/JobDB.py index 72a3612fb2e..32729e2a8d3 100755 --- a/src/DIRAC/WorkloadManagementSystem/DB/JobDB.py +++ b/src/DIRAC/WorkloadManagementSystem/DB/JobDB.py @@ -252,7 +252,7 @@ def getJobAttributes(self, jobID, attrList=None): result = self.getJobsAttributes([jobID], attrList) if not result["OK"]: return result - return S_OK(result["Value"].get(jobID, {})) + return S_OK(result["Value"].get(int(jobID), {})) ############################################################################# def getJobAttribute(self, jobID, attribute): @@ -270,7 +270,7 @@ def getJobParameter(self, jobID, parameter): result = self.getJobParameters(jobID, [parameter]) if not result["OK"]: return result - return S_OK(result.get("Value", {}).get(jobID, {}).get(parameter)) + return S_OK(result.get("Value", {}).get(int(jobID), {}).get(parameter)) ############################################################################# def getJobOptParameter(self, jobID, parameter): @@ -1118,7 +1118,7 @@ def rescheduleJob(self, jobID): result = JobMonitoringClient().getJobParameters(jobID) if result["OK"]: parDict = result["Value"] - for key, value in parDict.get(jobID, {}).items(): + for key, value in parDict.get(int(jobID), {}).items(): result = self.setAtticJobParameter(jobID, key, value, rescheduleCounter - 1) if not result["OK"]: break