kalluripradeep opened a new pull request, #63050: URL: https://github.com/apache/airflow/pull/63050
When the Celery worker starts, it imports `app` from `celery_executor.py` but `celery_executor_utils.py` was never imported at module level. This means `execute_command` never gets registered as a Celery task when the worker boots, and the `celery_import_modules` signal handler never connects. This worked before because older Celery versions were more lenient about when tasks got registered. Celery provider 3.17.0 exposed this — workers start receiving messages before `_process_tasks()` is ever called, so `execute_command` is unknown and messages get discarded: KeyError: 'execute_command' Received unregistered task of type 'execute_command'. The message has been ignored and discarded. Fix is a single import in `celery_executor.py` so `celery_executor_utils` is loaded when the worker imports `app` at startup. Fixes #63043 -- 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]
