ccoliu commented on issue #74459: URL: https://github.com/apache/airflow/issues/74459#issuecomment-6085272295
Tested **celery 3.25.0rc1** with `apache/airflow:3.3.2` and `[operators] default_queue = custom_queue`: **Use configured default queue for Celery executor callbacks (#73552)** works as expected. Passing an `ExecuteCallback` workload to `CeleryExecutor._process_workloads` and checking the queue it is sent to: | Callback | celery 3.24.1 | celery 3.25.0rc1 | |---|---|---| | no `queue` in callback data | `default` ❌ | `custom_queue` ✅ | | `queue` set in callback data | `callback_queue` | `callback_queue` ✅ | The configured default queue is now used, and a queue set in the callback data still takes precedence. -- 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]
