This is an automated email from the ASF dual-hosted git repository.

jscheffl pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 33fa95c176a Compat sdk conf follow-up: Celery, Common AI, FAB, Edge3 
(#64292)
33fa95c176a is described below

commit 33fa95c176ae1c02ea036fabd848e9b5d46fc28c
Author: Yuseok Jo <[email protected]>
AuthorDate: Sat Mar 28 19:12:44 2026 +0900

    Compat sdk conf follow-up: Celery, Common AI, FAB, Edge3 (#64292)
---
 providers/celery/src/airflow/providers/celery/cli/celery_command.py    | 2 +-
 providers/celery/src/airflow/providers/celery/cli/definition.py        | 2 +-
 providers/celery/tests/unit/celery/cli/test_celery_command.py          | 2 +-
 providers/common/ai/src/airflow/providers/common/ai/durable/storage.py | 2 +-
 providers/edge3/tests/unit/edge3/executors/test_edge_executor.py       | 3 +--
 providers/fab/tests/unit/fab/auth_manager/cli_commands/test_utils.py   | 2 +-
 6 files changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/providers/celery/src/airflow/providers/celery/cli/celery_command.py 
b/providers/celery/src/airflow/providers/celery/cli/celery_command.py
index 9121a579936..685163042b8 100644
--- a/providers/celery/src/airflow/providers/celery/cli/celery_command.py
+++ b/providers/celery/src/airflow/providers/celery/cli/celery_command.py
@@ -35,9 +35,9 @@ from lockfile.pidlockfile import read_pid_from_pidfile, 
remove_existing_pidfile
 
 from airflow import settings
 from airflow.cli.simple_table import AirflowConsole
-from airflow.configuration import conf
 from airflow.exceptions import AirflowConfigException
 from airflow.providers.celery.version_compat import AIRFLOW_V_3_0_PLUS, 
AIRFLOW_V_3_2_PLUS
+from airflow.providers.common.compat.sdk import conf
 from airflow.utils import cli as cli_utils
 from airflow.utils.cli import setup_locations
 
diff --git a/providers/celery/src/airflow/providers/celery/cli/definition.py 
b/providers/celery/src/airflow/providers/celery/cli/definition.py
index 6d6b5fcb894..ed8450dc22c 100644
--- a/providers/celery/src/airflow/providers/celery/cli/definition.py
+++ b/providers/celery/src/airflow/providers/celery/cli/definition.py
@@ -33,7 +33,7 @@ from airflow.cli.cli_config import (
     GroupCommand,
     lazy_load_command,
 )
-from airflow.configuration import conf
+from airflow.providers.common.compat.sdk import conf
 
 if TYPE_CHECKING:
     import argparse
diff --git a/providers/celery/tests/unit/celery/cli/test_celery_command.py 
b/providers/celery/tests/unit/celery/cli/test_celery_command.py
index b9d0de9f384..cafd48f29a0 100644
--- a/providers/celery/tests/unit/celery/cli/test_celery_command.py
+++ b/providers/celery/tests/unit/celery/cli/test_celery_command.py
@@ -30,10 +30,10 @@ from unittest.mock import MagicMock, patch
 import pytest
 
 from airflow.cli import cli_parser
-from airflow.configuration import conf
 from airflow.executors import executor_loader
 from airflow.providers.celery.cli import celery_command
 from airflow.providers.celery.cli.celery_command import _bundle_cleanup_main, 
_run_stale_bundle_cleanup
+from airflow.providers.common.compat.sdk import conf
 
 from tests_common.test_utils.config import conf_vars
 from tests_common.test_utils.version_compat import AIRFLOW_V_3_0_PLUS, 
AIRFLOW_V_3_2_PLUS
diff --git 
a/providers/common/ai/src/airflow/providers/common/ai/durable/storage.py 
b/providers/common/ai/src/airflow/providers/common/ai/durable/storage.py
index 7a6a03e33b7..3129aa8dfe2 100644
--- a/providers/common/ai/src/airflow/providers/common/ai/durable/storage.py
+++ b/providers/common/ai/src/airflow/providers/common/ai/durable/storage.py
@@ -35,7 +35,7 @@ SECTION = "common.ai"
 
 @lru_cache(maxsize=1)
 def _get_base_path():
-    from airflow.configuration import conf
+    from airflow.providers.common.compat.sdk import conf
     from airflow.sdk import ObjectStoragePath
 
     path = conf.get(SECTION, "durable_cache_path", fallback="")
diff --git a/providers/edge3/tests/unit/edge3/executors/test_edge_executor.py 
b/providers/edge3/tests/unit/edge3/executors/test_edge_executor.py
index c38dffed3e9..4bc0fb2f07c 100644
--- a/providers/edge3/tests/unit/edge3/executors/test_edge_executor.py
+++ b/providers/edge3/tests/unit/edge3/executors/test_edge_executor.py
@@ -23,9 +23,8 @@ import pytest
 import time_machine
 from sqlalchemy import delete, select
 
-from airflow.configuration import conf
 from airflow.models.taskinstancekey import TaskInstanceKey
-from airflow.providers.common.compat.sdk import Stats, timezone
+from airflow.providers.common.compat.sdk import Stats, conf, timezone
 from airflow.providers.edge3.executors.edge_executor import EdgeExecutor
 from airflow.providers.edge3.models.edge_job import EdgeJobModel
 from airflow.providers.edge3.models.edge_worker import EdgeWorkerModel, 
EdgeWorkerState
diff --git 
a/providers/fab/tests/unit/fab/auth_manager/cli_commands/test_utils.py 
b/providers/fab/tests/unit/fab/auth_manager/cli_commands/test_utils.py
index 633850e0df6..0acf228957c 100644
--- a/providers/fab/tests/unit/fab/auth_manager/cli_commands/test_utils.py
+++ b/providers/fab/tests/unit/fab/auth_manager/cli_commands/test_utils.py
@@ -21,8 +21,8 @@ import os
 import pytest
 
 import airflow
-from airflow.configuration import conf
 from airflow.exceptions import AirflowConfigException
+from airflow.providers.common.compat.sdk import conf
 from airflow.providers.fab.auth_manager.cli_commands.utils import 
get_application_builder
 from airflow.providers.fab.www.extensions.init_appbuilder import 
AirflowAppBuilder
 from airflow.providers.fab.www.session import AirflowDatabaseSessionInterface

Reply via email to