diff --git a/task-sdk/src/airflow/sdk/bases/operatorlink.py b/task-sdk/src/airflow/sdk/bases/operatorlink.py index 43ffe0725f5d5..06f5e4d98e72f 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 29f5fce7d1bfc..cd5b6cc9a709d 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 1f3dc67666b14..acf607baad06f 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, )