diff --git a/airflow/providers/celery/executors/celery_executor.py b/airflow/providers/celery/executors/celery_executor.py index 93037bb31c136..bddea8bd2879a 100644 --- a/airflow/providers/celery/executors/celery_executor.py +++ b/airflow/providers/celery/executors/celery_executor.py @@ -54,6 +54,9 @@ from airflow.configuration import conf from airflow.exceptions import AirflowTaskTimeout from airflow.executors.base_executor import BaseExecutor +from airflow.providers.celery.executors import ( + celery_executor_utils as _celery_executor_utils, # noqa: F401 # Needed to register execute_command with Celery app at worker startup, see #63043 +) from airflow.stats import Stats from airflow.utils.state import TaskInstanceState