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(

Reply via email to