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 d889b97660a Correct some cross references in shared library and sdk
plugins_manager (#60698)
d889b97660a is described below
commit d889b97660abf2e0be1d6ff877cbf3920d30c90a
Author: Amogh Desai <[email protected]>
AuthorDate: Tue Jan 20 19:23:34 2026 +0530
Correct some cross references in shared library and sdk plugins_manager
(#60698)
---
shared/plugins_manager/pyproject.toml | 1 +
.../src/airflow_shared/plugins_manager/plugins_manager.py | 2 +-
task-sdk/src/airflow/sdk/plugins_manager.py | 2 +-
3 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/shared/plugins_manager/pyproject.toml
b/shared/plugins_manager/pyproject.toml
index 059a552da29..769e8a0b537 100644
--- a/shared/plugins_manager/pyproject.toml
+++ b/shared/plugins_manager/pyproject.toml
@@ -34,6 +34,7 @@ dependencies = [
dev = [
"apache-airflow-devel-common",
"apache-airflow-shared-module-loading",
+ "apache-airflow-shared-listeners",
]
[build-system]
diff --git
a/shared/plugins_manager/src/airflow_shared/plugins_manager/plugins_manager.py
b/shared/plugins_manager/src/airflow_shared/plugins_manager/plugins_manager.py
index 59761f6117b..e7fbb24377f 100644
---
a/shared/plugins_manager/src/airflow_shared/plugins_manager/plugins_manager.py
+++
b/shared/plugins_manager/src/airflow_shared/plugins_manager/plugins_manager.py
@@ -35,7 +35,7 @@ if TYPE_CHECKING:
from collections.abc import Generator
from types import ModuleType
- from airflow.listeners.listener import ListenerManager
+ from ..listeners.listener import ListenerManager
log = logging.getLogger(__name__)
diff --git a/task-sdk/src/airflow/sdk/plugins_manager.py
b/task-sdk/src/airflow/sdk/plugins_manager.py
index bdb9fd9ec0e..2cbdf1a44a4 100644
--- a/task-sdk/src/airflow/sdk/plugins_manager.py
+++ b/task-sdk/src/airflow/sdk/plugins_manager.py
@@ -38,7 +38,7 @@ from airflow.sdk.configuration import conf
from airflow.sdk.providers_manager_runtime import ProvidersManagerTaskRuntime
if TYPE_CHECKING:
- from airflow.listeners.listener import ListenerManager
+ from airflow.sdk._shared.listeners.listener import ListenerManager
log = logging.getLogger(__name__)
