Airflow generate dynamic task

airflow_dynamic_task.py

# Using DummyOperator
a = []
for i in range(0,10):
    a.append(DummyOperator(
        task_id='Component'+str(i),
        dag=dag))
    if i != 0: 
        a[i-1] >> a[i]

# From a List
sample_list = ["val1", "val2", "val3"]
tasks_list = []
for index, value in enumerate(sample_list):
    tasks_list.append(DummyOperator(
        task_id='Component'+str(index),
        dag=dag))
    if index != 0: 
        tasks_list[index-1] >> tasks_list[index]