From f20fa122a512058f306e9cd79c322f354d3e1033 Mon Sep 17 00:00:00 2001 From: kyungjunleeme Date: Tue, 1 Jul 2025 08:19:33 +0900 Subject: [PATCH 1/2] ADD: add conditional import for BaseOperator --- .../src/airflow/providers/presto/version_compat.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/providers/presto/src/airflow/providers/presto/version_compat.py b/providers/presto/src/airflow/providers/presto/version_compat.py index 48d122b669696..e7a259afb357c 100644 --- a/providers/presto/src/airflow/providers/presto/version_compat.py +++ b/providers/presto/src/airflow/providers/presto/version_compat.py @@ -33,3 +33,13 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]: AIRFLOW_V_3_0_PLUS = get_base_airflow_version_tuple() >= (3, 0, 0) + +if AIRFLOW_V_3_0_PLUS: + from airflow.sdk import BaseOperator +else: + from airflow.models import BaseOperator + +__all__ = [ + "AIRFLOW_V_3_0_PLUS", + "BaseOperator", +] From 3ab01049eaf8b6e077dc4cc8415291dc4aea9fbd Mon Sep 17 00:00:00 2001 From: kyungjunleeme Date: Tue, 1 Jul 2025 08:23:08 +0900 Subject: [PATCH 2/2] CHG: change import path --- .../src/airflow/providers/presto/transfers/gcs_to_presto.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/providers/presto/src/airflow/providers/presto/transfers/gcs_to_presto.py b/providers/presto/src/airflow/providers/presto/transfers/gcs_to_presto.py index d64ecbfbee170..ed53a3fc0811f 100644 --- a/providers/presto/src/airflow/providers/presto/transfers/gcs_to_presto.py +++ b/providers/presto/src/airflow/providers/presto/transfers/gcs_to_presto.py @@ -25,9 +25,9 @@ from tempfile import NamedTemporaryFile from typing import TYPE_CHECKING -from airflow.models import BaseOperator from airflow.providers.google.cloud.hooks.gcs import GCSHook from airflow.providers.presto.hooks.presto import PrestoHook +from airflow.providers.presto.version_compat import BaseOperator if TYPE_CHECKING: try: