This is an automated email from the ASF dual-hosted git repository.
jasonliu pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new 75789fe6a77 [v3-1-test] fix: correct typo in function name
_set_runing_task (#61496) (#61619)
75789fe6a77 is described below
commit 75789fe6a77cc4c5b7e973ac1bf3f6d786f5d931
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Feb 8 17:19:10 2026 +0800
[v3-1-test] fix: correct typo in function name _set_runing_task (#61496)
(#61619)
(cherry picked from commit 7dbe533a73428cd2ee5f8d09d2b1e1a0cce78759)
Co-authored-by: André Ahlert <[email protected]>
---
airflow-core/src/airflow/api/common/mark_tasks.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/api/common/mark_tasks.py
b/airflow-core/src/airflow/api/common/mark_tasks.py
index 5c0ed4b9f5f..0024e29f353 100644
--- a/airflow-core/src/airflow/api/common/mark_tasks.py
+++ b/airflow-core/src/airflow/api/common/mark_tasks.py
@@ -306,11 +306,11 @@ def set_dag_run_state_to_failed(
# Do not kill teardown tasks
task_ids_of_running_tis = {ti.task_id for ti in running_tis if not
dag.task_dict[ti.task_id].is_teardown}
- def _set_runing_task(task: Operator) -> Operator:
+ def _set_running_task(task: Operator) -> Operator:
task.dag = dag
return task
- running_tasks = [_set_runing_task(task) for task in dag.tasks if
task.task_id in task_ids_of_running_tis]
+ running_tasks = [_set_running_task(task) for task in dag.tasks if
task.task_id in task_ids_of_running_tis]
# Mark non-finished tasks as SKIPPED.
pending_tis: list[TaskInstance] = session.scalars(