diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py index fd43bac215925ab347d916d672e630fbbeca2cad..07a42abb8927730a1168ce02edd81a2be2c04210 100644 --- a/webservice/job_monitor.py +++ b/webservice/job_monitor.py @@ -148,12 +148,12 @@ class JobsMonitor: ongoing_jobs_by_exn = {} for r in c.fetchall(): - log.debug(f"DB info {r}") + log.debug(f"Job in DB before update: %s", tuple(r)) execn_ongoing_jobs = ongoing_jobs_by_exn.setdefault(r['exec_id'], []) - if r['job_id'] in statii: + if str(r['job_id']) in statii: # statii contains jobs which are still going (from squeue) - slstatus, runtime = statii[r['job_id']] + slstatus, runtime = statii[str(r['job_id'])] finished = False execn_ongoing_jobs.append(f"{slstatus}-{runtime}")