Update airflow/models/baseoperator.py

Co-authored-by: Jed Cunningham <[email protected]>
apache · Feb 6, 2025 · ce36e6d · ce36e6d
1 parent 696c74d
commit ce36e6d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/models/baseoperator.py b/airflow/models/baseoperator.py
@@ -853,7 +853,7 @@ def _(cls, task: MappedOperator, run_id: str, *, session: Session) -> int:
             exp_input = task._get_specified_expand_input()
             if isinstance(exp_input, _ExpandInputRef):
                 exp_input = exp_input.deref(task.dag)
-            # TODO: TaskSDK This is only needed to support `dag.test()` etc until we port it over ot use the
+            # TODO: TaskSDK This is only needed to support `dag.test()` etc until we port it over to use the
             # task sdk runner.
             if not hasattr(exp_input, "get_total_map_length"):
                 exp_input = _ExpandInputRef(