diff --git a/backend/fluksio/flow/runs.py b/backend/fluksio/flow/runs.py index 476bed4..31ecee0 100644 --- a/backend/fluksio/flow/runs.py +++ b/backend/fluksio/flow/runs.py @@ -1430,6 +1430,8 @@ class RunService: .where(col(Run.id) == run_id, col(Run.status) == "queued") .values( status="running", + # A "Waiting for a worker" from the queue no longer holds. + status_reason="", started_at=now, lease_at=now, engine=self.engine_name,