This is an automated email from the ASF dual-hosted git repository.
amoghdesai 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 cff919e2e98 Use task sdk module_loading helpers for task sdk (#58555)
cff919e2e98 is described below
commit cff919e2e98c714ae384a12cabea1438bbcea923
Author: Amogh Desai <[email protected]>
AuthorDate: Fri Nov 21 18:59:54 2025 +0530
Use task sdk module_loading helpers for task sdk (#58555)
---
task-sdk/src/airflow/sdk/configuration.py | 2 +-
task-sdk/tests/task_sdk/execution_time/test_sentry.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/configuration.py
b/task-sdk/src/airflow/sdk/configuration.py
index 3f00d0a227b..a9f3d09f584 100644
--- a/task-sdk/src/airflow/sdk/configuration.py
+++ b/task-sdk/src/airflow/sdk/configuration.py
@@ -195,7 +195,7 @@ def initialize_secrets_backends(
Uses SDK's conf instead of Core's conf.
"""
- from airflow.utils.module_loading import import_string
+ from airflow.sdk.module_loading import import_string
backend_list = []
worker_mode = False
diff --git a/task-sdk/tests/task_sdk/execution_time/test_sentry.py
b/task-sdk/tests/task_sdk/execution_time/test_sentry.py
index b68add79e29..5aaaada2c5f 100644
--- a/task-sdk/tests/task_sdk/execution_time/test_sentry.py
+++ b/task-sdk/tests/task_sdk/execution_time/test_sentry.py
@@ -31,7 +31,7 @@ from airflow.providers.standard.operators.python import
PythonOperator
from airflow.sdk.api.datamodels._generated import DagRun, DagRunState,
DagRunType
from airflow.sdk.execution_time.comms import GetTaskBreadcrumbs,
TaskBreadcrumbsResult
from airflow.sdk.execution_time.task_runner import RuntimeTaskInstance
-from airflow.utils.module_loading import import_string
+from airflow.sdk.module_loading import import_string
from airflow.utils.state import State
from tests_common.test_utils.config import conf_vars
