Jenia Varavva
05/19/2023, 6:03 PMprefect agent start --pool data-qa
and some env vars (as set by prefect-agent helm). The agent picks up work from the queue and launches it fine, but the cancellations don't work. Looking at the agent code, there's a chain of calls: check_for_cancelled_flow_runs -> Agent.get_work_queues() -> update_matched_agent_work_queues() with the last one containing a condition on the whole method body:
if self.work_queue_prefix:
and not doing anything otherwise. Since I don't set work_queue_prefix on the CLI, the agent ends up not matching any queues, so the flows in Cancelling
state never get processed. Is this a bug or am I doing something wrong?-q default
to the CLI resolves the issueZanie
05/19/2023, 11:51 PMJenia Varavva
05/20/2023, 12:25 AM