diff --git a/providers/airbyte/src/airflow/providers/airbyte/operators/airbyte.py b/providers/airbyte/src/airflow/providers/airbyte/operators/airbyte.py index 596765c4a5c53..c2091d61cb1a0 100644 --- a/providers/airbyte/src/airflow/providers/airbyte/operators/airbyte.py +++ b/providers/airbyte/src/airflow/providers/airbyte/operators/airbyte.py @@ -27,15 +27,10 @@ from airflow.exceptions import AirflowException from airflow.providers.airbyte.hooks.airbyte import AirbyteHook from airflow.providers.airbyte.triggers.airbyte import AirbyteSyncTrigger -from airflow.providers.airbyte.version_compat import AIRFLOW_V_3_0_PLUS - -if AIRFLOW_V_3_0_PLUS: - from airflow.sdk import BaseOperator -else: - from airflow.models import BaseOperator +from airflow.providers.airbyte.version_compat import BaseOperator if TYPE_CHECKING: - from airflow.utils.context import Context + from airflow.providers.airbyte.version_compat import Context class AirbyteTriggerSyncOperator(BaseOperator): diff --git a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py index be13a31e7de6e..e8a7d1e2e4bf8 100644 --- a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py +++ b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py @@ -29,15 +29,10 @@ from airflow.exceptions import AirflowException from airflow.providers.airbyte.hooks.airbyte import AirbyteHook from airflow.providers.airbyte.triggers.airbyte import AirbyteSyncTrigger -from airflow.providers.airbyte.version_compat import AIRFLOW_V_3_0_PLUS - -if AIRFLOW_V_3_0_PLUS: - from airflow.sdk import BaseSensorOperator -else: - from airflow.sensors.base import BaseSensorOperator # type: ignore[no-redef] +from airflow.providers.airbyte.version_compat import BaseSensorOperator if TYPE_CHECKING: - from airflow.utils.context import Context + from airflow.providers.airbyte.version_compat import Context class AirbyteJobSensor(BaseSensorOperator): diff --git a/providers/airbyte/src/airflow/providers/airbyte/version_compat.py b/providers/airbyte/src/airflow/providers/airbyte/version_compat.py index 48d122b669696..5faab587ffcef 100644 --- a/providers/airbyte/src/airflow/providers/airbyte/version_compat.py +++ b/providers/airbyte/src/airflow/providers/airbyte/version_compat.py @@ -33,3 +33,18 @@ 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, BaseSensorOperator + from airflow.sdk.definitions.context import Context +else: + from airflow.models import BaseOperator + from airflow.sensors.base import BaseSensorOperator # type: ignore[no-redef] + from airflow.utils.context import Context + +__all__ = [ + "AIRFLOW_V_3_0_PLUS", + "BaseOperator", + "BaseSensorOperator", + "Context", +]