Skip to content

Commit 74fe559

Browse files
authored
Merge pull request #7435 from andresailer/80_fixJobIDs
[8.0] fix(JobDB): getJobParameters and getJobsAttributes use integer jobIDs…
2 parents 0f7e63b + b4f9486 commit 74fe559

File tree

1 file changed

+3
-3
lines changed
  • src/DIRAC/WorkloadManagementSystem/DB

1 file changed

+3
-3
lines changed

src/DIRAC/WorkloadManagementSystem/DB/JobDB.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,7 @@ def getJobAttributes(self, jobID, attrList=None):
252252
result = self.getJobsAttributes([jobID], attrList)
253253
if not result["OK"]:
254254
return result
255-
return S_OK(result["Value"].get(jobID, {}))
255+
return S_OK(result["Value"].get(int(jobID), {}))
256256

257257
#############################################################################
258258
def getJobAttribute(self, jobID, attribute):
@@ -270,7 +270,7 @@ def getJobParameter(self, jobID, parameter):
270270
result = self.getJobParameters(jobID, [parameter])
271271
if not result["OK"]:
272272
return result
273-
return S_OK(result.get("Value", {}).get(jobID, {}).get(parameter))
273+
return S_OK(result.get("Value", {}).get(int(jobID), {}).get(parameter))
274274

275275
#############################################################################
276276
def getJobOptParameter(self, jobID, parameter):
@@ -1140,7 +1140,7 @@ def rescheduleJob(self, jobID):
11401140
result = JobMonitoringClient().getJobParameters(jobID)
11411141
if result["OK"]:
11421142
parDict = result["Value"]
1143-
for key, value in parDict.get(jobID, {}).items():
1143+
for key, value in parDict.get(int(jobID), {}).items():
11441144
result = self.setAtticJobParameter(jobID, key, value, rescheduleCounter - 1)
11451145
if not result["OK"]:
11461146
break

0 commit comments

Comments
 (0)