Aakcht opened a new issue, #63729: URL: https://github.com/apache/airflow/issues/63729
### Apache Airflow Provider(s) celery ### Versions of Apache Airflow Providers _No response_ ### Apache Airflow version 2.11.2 ### Operating System debian ### Deployment Official Apache Airflow Helm Chart ### Deployment details _No response_ ### What happened The same issue as in https://github.com/apache/airflow/issues/63043 can be observed on Airflow 2.11.2 and Celery provider 3.17.1. ### What you think should happen instead The issue should not be present ### How to reproduce It is possible see that the issue is still present by running the new test logic from https://github.com/apache/airflow/pull/63110/changes in Airflow 2. ### Anything else Looks like https://github.com/apache/airflow/pull/63110 was supposed to fix the issue, but for some reason it didn't fix it for Airflow 2. The issue can be observed in `apache/airflow:slim-2.11.2` image after adding `apache-airflow-providers-celery==3.17.1` provider. If you try to execute logic from the new test from https://github.com/apache/airflow/pull/63110 the following happens: ``` (airflow)pip list | grep airflow apache-airflow 2.11.2 apache-airflow-providers-celery 3.17.1 apache-airflow-providers-common-compat 1.14.0 apache-airflow-providers-common-io 1.7.1 apache-airflow-providers-common-sql 1.32.0 apache-airflow-providers-fab 1.5.4 apache-airflow-providers-ftp 3.14.1 apache-airflow-providers-http 6.0.0 apache-airflow-providers-imap 3.11.0 apache-airflow-providers-smtp 2.4.2 apache-airflow-providers-sqlite 4.3.0 (airflow)python Python 3.12.13 (main, Mar 3 2026, 20:23:52) [GCC 12.2.0] on linux Type "help", "copyright", "credits" or "license" for more information. >>> from airflow.providers.celery.executors.celery_executor_utils import app /home/airflow/.local/lib/python3.12/site-packages/airflow/metrics/base_stats_logger.py:22 RemovedInAirflow3Warning: Timer and timing metrics publish in seconds were deprecated. It is enabled by default from Airflow 3 onwards. Enable timer_unit_consistency to publish all the timer and timing metrics in milliseconds. >>> registered_tasks = list(app.tasks.keys()) >>> assert "execute_command" in registered_tasks, ("execute_command must be registered for Airflow 2.x compatibility.") Traceback (most recent call last): File "<stdin>", line 1, in <module> AssertionError: execute_command must be registered for Airflow 2.x compatibility. >>> print(registered_tasks) ['execute_workload', 'celery.group', 'celery.map', 'celery.backend_cleanup', 'airflow.providers.celery.executors.celery_executor_utils.execute_command', 'celery.chain', 'celery.starmap', 'celery.accumulate', 'celery.chord', 'celery.chunks', 'celery.chord_unlock'] ``` ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md) -- 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]
