From bd22d2c761fefb86c81f5f763e91502294c07bc6 Mon Sep 17 00:00:00 2001 From: Kenan Adel Date: Sat, 20 Jun 2026 22:59:29 +0300 Subject: [PATCH] Remove stale `dag_` parameter from create_test_pipeline docstring --- airflow-core/src/airflow/example_dags/example_skip_dag.py | 1 - 1 file changed, 1 deletion(-) diff --git a/airflow-core/src/airflow/example_dags/example_skip_dag.py b/airflow-core/src/airflow/example_dags/example_skip_dag.py index a2fe914c0356d..f5eed85f2de17 100644 --- a/airflow-core/src/airflow/example_dags/example_skip_dag.py +++ b/airflow-core/src/airflow/example_dags/example_skip_dag.py @@ -48,7 +48,6 @@ def create_test_pipeline(suffix, trigger_rule): :param str suffix: Suffix to append to the operator task_ids :param str trigger_rule: TriggerRule for the join task - :param DAG dag_: The DAG to run the operators on """ skip_operator = EmptySkipOperator(task_id=f"skip_operator_{suffix}") always_true = EmptyOperator(task_id=f"always_true_{suffix}")