kalluripradeep opened a new pull request, #63110: URL: https://github.com/apache/airflow/pull/63110
Follow-up to #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_workload` (and `execute_command` for Airflow 2.x) are never registered as Celery tasks when the worker boots, causing: KeyError: 'execute_command' KeyError: 'execute_workload' Received unregistered task of type '...'. The message has been ignored and discarded. Fix is a single module-level import in `celery_executor.py` so `celery_executor_utils` is loaded when the worker imports `app` at startup, ensuring all tasks are registered immediately. Also adds a regression test to verify task registration on import. 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]
