Skip to content

Commit

Permalink
Add missing "example" tag on example DAG (apache#11253)
Browse files Browse the repository at this point in the history
`example_task_group` and `example_nested_branch_dag` didn't have the example tag while all the other ones do have it
  • Loading branch information
kaxil authored Oct 3, 2020
1 parent 6d573e8 commit ee81266
Showing 2 changed files with 7 additions and 2 deletions.
7 changes: 6 additions & 1 deletion airflow/example_dags/example_nested_branch_dag.py
Original file line number Diff line number Diff line change
@@ -27,7 +27,12 @@
from airflow.operators.python import BranchPythonOperator
from airflow.utils.dates import days_ago

with DAG(dag_id="example_nested_branch_dag", start_date=days_ago(2), schedule_interval="@daily") as dag:
with DAG(
dag_id="example_nested_branch_dag",
start_date=days_ago(2),
schedule_interval="@daily",
tags=["example"]
) as dag:
branch_1 = BranchPythonOperator(task_id="branch_1", python_callable=lambda: "true_1")
join_1 = DummyOperator(task_id="join_1", trigger_rule="none_failed_or_skipped")
true_1 = DummyOperator(task_id="true_1")
2 changes: 1 addition & 1 deletion airflow/example_dags/example_task_group.py
Original file line number Diff line number Diff line change
@@ -25,7 +25,7 @@
from airflow.utils.task_group import TaskGroup

# [START howto_task_group]
with DAG(dag_id="example_task_group", start_date=days_ago(2)) as dag:
with DAG(dag_id="example_task_group", start_date=days_ago(2), tags=["example"]) as dag:
start = DummyOperator(task_id="start")

# [START howto_task_group_section_1]

0 comments on commit ee81266

Please sign in to comment.