From 67a4a252755a26fd740ff46224b74c4745fa09f0 Mon Sep 17 00:00:00 2001
From: Thomas Kluyver <thomas@kluyver.me.uk>
Date: Tue, 24 May 2022 17:33:43 +0100
Subject: [PATCH] Convert job_ids to str for dict from slurm_status()
---
webservice/job_monitor.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index fd43bac21..07a42abb8 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}")
--
GitLab