Commit 38ebf606 authored by Daniele Venzano's avatar Daniele Venzano

Fix exception for recovered executions after restart

parent f95fdc11
...@@ -54,6 +54,7 @@ class ZoeElasticScheduler: ...@@ -54,6 +54,7 @@ class ZoeElasticScheduler:
self.queue_running.append(execution) self.queue_running.append(execution)
else: else:
self.queue.append(execution) self.queue.append(execution)
self.additional_exec_state[] = ExecutionProgress(0, [])
def trigger(self): def trigger(self):
"""Trigger a scheduler run.""" """Trigger a scheduler run."""
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment