Skip to content

Commit c9e2ab3

Browse files
phicharpchrisburr
authored andcommitted
sweep: #5946 Escape Time stamp in JobDB
1 parent d9dd4c7 commit c9e2ab3

File tree

1 file changed

+5
-1
lines changed
  • src/DIRAC/WorkloadManagementSystem/DB

1 file changed

+5
-1
lines changed

src/DIRAC/WorkloadManagementSystem/DB/JobDB.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1921,7 +1921,11 @@ def setHeartBeatData(self, jobID, dynamicDataDict):
19211921
# If HeartBeatTime is being set, set it...
19221922
timeStamp = dynamicDataDict.pop("HeartBeatTime", None)
19231923
if timeStamp:
1924-
req = f"UPDATE Jobs SET HeartBeatTime={timeStamp} WHERE JobID={e_jobID}"
1924+
result = self._escapeString(timeStamp)
1925+
if not result["OK"]:
1926+
self.log.warn("Failed to escape string ", timeStamp)
1927+
return result
1928+
req = f"UPDATE Jobs SET HeartBeatTime={result['Value']} WHERE JobID={e_jobID}"
19251929
else:
19261930
req = f"UPDATE Jobs SET HeartBeatTime=UTC_TIMESTAMP(), Status='{JobStatus.RUNNING}' WHERE JobID={e_jobID}"
19271931

0 commit comments

Comments
 (0)