Skip to content

Commit 6654c15

Browse files
authored
Move all BaseHook usages to version_compat in teradata provider (#52858)
* Move BaseHook to version_compat * Move BaseHook to version_compat
1 parent b40ad46 commit 6654c15

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

providers/teradata/src/airflow/providers/teradata/hooks/ttu.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,7 @@
2222
from typing import Any
2323

2424
from airflow.exceptions import AirflowException
25-
26-
try:
27-
from airflow.sdk import BaseHook
28-
except ImportError:
29-
from airflow.hooks.base import BaseHook # type: ignore[attr-defined,no-redef]
25+
from airflow.providers.teradata.version_compat import BaseHook
3026

3127

3228
class TtuHook(BaseHook, ABC):

providers/teradata/src/airflow/providers/teradata/version_compat.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,16 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]:
3333

3434

3535
AIRFLOW_V_3_0_PLUS = get_base_airflow_version_tuple() >= (3, 0, 0)
36+
AIRFLOW_V_3_1_PLUS: bool = get_base_airflow_version_tuple() >= (3, 1, 0)
37+
38+
if AIRFLOW_V_3_1_PLUS:
39+
from airflow.sdk import BaseHook
40+
else:
41+
from airflow.hooks.base import BaseHook # type: ignore[attr-defined,no-redef]
3642

3743
if AIRFLOW_V_3_0_PLUS:
3844
from airflow.sdk import BaseOperator
3945
else:
4046
from airflow.models import BaseOperator # type: ignore[no-redef]
4147

42-
__all__ = ["AIRFLOW_V_3_0_PLUS", "BaseOperator"]
48+
__all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS", "BaseHook", "BaseOperator"]

0 commit comments

Comments
 (0)