diff --git a/providers/jenkins/src/airflow/providers/jenkins/hooks/jenkins.py b/providers/jenkins/src/airflow/providers/jenkins/hooks/jenkins.py index 3d8958a43c19b..0c605568a80dc 100644 --- a/providers/jenkins/src/airflow/providers/jenkins/hooks/jenkins.py +++ b/providers/jenkins/src/airflow/providers/jenkins/hooks/jenkins.py @@ -21,10 +21,7 @@ import jenkins -try: - from airflow.sdk import BaseHook -except ImportError: - from airflow.hooks.base import BaseHook # type: ignore[attr-defined,no-redef] +from airflow.providers.jenkins.version_compat import BaseHook class JenkinsHook(BaseHook): diff --git a/providers/jenkins/src/airflow/providers/jenkins/version_compat.py b/providers/jenkins/src/airflow/providers/jenkins/version_compat.py index da54ff9f75652..17b4d7fb29514 100644 --- a/providers/jenkins/src/airflow/providers/jenkins/version_compat.py +++ b/providers/jenkins/src/airflow/providers/jenkins/version_compat.py @@ -33,6 +33,12 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]: AIRFLOW_V_3_0_PLUS = get_base_airflow_version_tuple() >= (3, 0, 0) +AIRFLOW_V_3_1_PLUS: bool = get_base_airflow_version_tuple() >= (3, 1, 0) + +if AIRFLOW_V_3_1_PLUS: + from airflow.sdk import BaseHook +else: + from airflow.hooks.base import BaseHook # type: ignore[attr-defined,no-redef] if AIRFLOW_V_3_0_PLUS: from airflow.sdk import BaseOperator, BaseSensorOperator @@ -44,6 +50,8 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]: __all__ = [ "AIRFLOW_V_3_0_PLUS", + "AIRFLOW_V_3_1_PLUS", + "BaseHook", "BaseOperator", "BaseSensorOperator", "Context",