gistfile1.txt

"""
Example of sequential dynamic task creation
"""
from datetime import datetime, timedelta
from airflow import DAG, configuration
from airflow.operators.dummy_operator import DummyOperator

dag = DAG(
    dag_id="dynamic_tasks_example",
    start_date=datetime(2018, 2, 9),
    schedule_interval='15 * * * *',
    catchup=True,
)

start = DummyOperator(
    task_id='start',
    dag=dag
)
tasks = [start]
for t in ["task1", "task2", "task3"]:
    taskOp = DummyOperator(
    task_id=t,
    dag=dag)

    tasks[-1] >> taskOp
    tasks.append(taskOp)