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}")