|
29 | 29 | import subprocess |
30 | 30 | import sys |
31 | 31 | import traceback |
32 | | -import warnings |
33 | 32 | from collections.abc import Collection, Mapping, MutableMapping, Sequence |
34 | 33 | from concurrent.futures import ProcessPoolExecutor |
35 | 34 | from typing import TYPE_CHECKING, Any |
|
42 | 41 |
|
43 | 42 | import airflow.settings as settings |
44 | 43 | from airflow.configuration import conf |
45 | | -from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning, AirflowTaskTimeout |
| 44 | +from airflow.exceptions import AirflowException, AirflowTaskTimeout |
46 | 45 | from airflow.executors.base_executor import BaseExecutor |
47 | 46 | from airflow.providers.celery.version_compat import AIRFLOW_V_3_0_PLUS, timeout |
48 | 47 | from airflow.stats import Stats |
@@ -100,16 +99,6 @@ def _get_celery_app() -> Celery: |
100 | 99 | celery_configuration = DEFAULT_CELERY_CONFIG |
101 | 100 |
|
102 | 101 | celery_app_name = conf.get("celery", "CELERY_APP_NAME") |
103 | | - if celery_app_name == "airflow.executors.celery_executor": |
104 | | - warnings.warn( |
105 | | - "The celery.CELERY_APP_NAME configuration uses deprecated package name: " |
106 | | - "'airflow.executors.celery_executor'. " |
107 | | - "Change it to `airflow.providers.celery.executors.celery_executor`, and " |
108 | | - "update the `-app` flag in your Celery Health Checks " |
109 | | - "to use `airflow.providers.celery.executors.celery_executor.app`.", |
110 | | - AirflowProviderDeprecationWarning, |
111 | | - stacklevel=2, |
112 | | - ) |
113 | 102 |
|
114 | 103 | return Celery(celery_app_name, config_source=celery_configuration) |
115 | 104 |
|
|
0 commit comments