Do not remove outside queued

midokura · Apr 26, 2024 · 97b5515 · 97b5515
1 parent 009f3cb
commit 97b5515
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/app.py b/src/app.py
@@ -82,7 +82,6 @@ def process_workflow_job():
         node_ids[job.node_id] = job
 
     elif job.action == "in_progress":
-        node_ids.pop(job.node_id, None)
         job_requested = jobs.get(job.id)
         time_to_start = None
         if not job_requested:
@@ -110,7 +109,6 @@ def process_workflow_job():
         jobs[job.id] = job
 
     elif job.action == "completed":
-        node_ids.pop(job.node_id, None)
         job_requested = jobs.get(job.id)
         if not job_requested:
             app.logger.warning(f"Job {job.id} is {job.action} but not stored!")