diff --git a/task-sdk/src/airflow/sdk/bases/operatorlink.py b/task-sdk/src/airflow/sdk/bases/operatorlink.py index 06f5e4d98e72f..43ffe0725f5d5 100644 --- a/task-sdk/src/airflow/sdk/bases/operatorlink.py +++ b/task-sdk/src/airflow/sdk/bases/operatorlink.py @@ -23,8 +23,8 @@ import attrs if TYPE_CHECKING: - from airflow.models.baseoperator import BaseOperator from airflow.models.taskinstancekey import TaskInstanceKey + from airflow.sdk import BaseOperator @attrs.define() diff --git a/task-sdk/src/airflow/sdk/definitions/_internal/templater.py b/task-sdk/src/airflow/sdk/definitions/_internal/templater.py index cd5b6cc9a709d..29f5fce7d1bfc 100644 --- a/task-sdk/src/airflow/sdk/definitions/_internal/templater.py +++ b/task-sdk/src/airflow/sdk/definitions/_internal/templater.py @@ -32,9 +32,9 @@ from airflow.sdk.definitions.context import render_template_as_native, render_template_to_string if TYPE_CHECKING: - from airflow.models.operator import Operator from airflow.sdk.definitions.context import Context from airflow.sdk.definitions.dag import DAG + from airflow.sdk.types import Operator @dataclass(frozen=True) diff --git a/task-sdk/src/airflow/sdk/definitions/context.py b/task-sdk/src/airflow/sdk/definitions/context.py index acf607baad06f..1f3dc67666b14 100644 --- a/task-sdk/src/airflow/sdk/definitions/context.py +++ b/task-sdk/src/airflow/sdk/definitions/context.py @@ -26,12 +26,12 @@ import jinja2 from pendulum import DateTime - from airflow.models.operator import Operator from airflow.sdk.bases.operator import BaseOperator from airflow.sdk.definitions.dag import DAG from airflow.sdk.execution_time.context import InletEventsAccessors from airflow.sdk.types import ( DagRunProtocol, + Operator, OutletEventAccessorsProtocol, RuntimeTaskInstanceProtocol, )