This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new ee81266 Add missing "example" tag on example DAG (#11253)
ee81266 is described below
commit ee812665c946dec47cc683485a0c4a320c05dca4
Author: Kaxil Naik <[email protected]>
AuthorDate: Sat Oct 3 11:39:40 2020 +0100
Add missing "example" tag on example DAG (#11253)
`example_task_group` and `example_nested_branch_dag` didn't have the
example tag while all the other ones do have it
---
airflow/example_dags/example_nested_branch_dag.py | 7 ++++++-
airflow/example_dags/example_task_group.py | 2 +-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/airflow/example_dags/example_nested_branch_dag.py
b/airflow/example_dags/example_nested_branch_dag.py
index 90653a6..0050d9a 100644
--- a/airflow/example_dags/example_nested_branch_dag.py
+++ b/airflow/example_dags/example_nested_branch_dag.py
@@ -27,7 +27,12 @@ from airflow.operators.dummy_operator import DummyOperator
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")
diff --git a/airflow/example_dags/example_task_group.py
b/airflow/example_dags/example_task_group.py
index 90e733e..9002cd2 100644
--- a/airflow/example_dags/example_task_group.py
+++ b/airflow/example_dags/example_task_group.py
@@ -25,7 +25,7 @@ from airflow.utils.dates import days_ago
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]