ccoliu opened a new pull request, #73552:
URL: https://github.com/apache/airflow/pull/73552
CeleryExecutor hardcoded the `"default"` queue when dispatching
`ExecuteCallback` workloads (e.g. deadline `SyncCallback`s), ignoring
`[operators] default_queue`. In deployments where no Celery queue is named
`default`, these callbacks were never picked up by any worker.
This reads the queue from the executor's team-aware config
(`self.conf.get_mandatory_value("operators", "default_queue")`), matching how
the Edge executor routes callbacks. A `queue` set in the callback data still
takes precedence.
Tests: extended `test_process_workloads_routes_execute_callback` with a
configured-default-queue case and a case where the callback-data queue
overrides it. The new `configured_default_queue` case fails without the fix
(callback is routed to `'default'`) and passes with it.
closes: #73545
---
##### Was generative AI tooling used to co-author this PR?
- [X] Yes (please specify the tool below)
Generated-by: Claude Code (Claude Opus 5) following [the
guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions)
Generated with [Claude Code](https://claude.com/claude-code)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
