a dag with tasks that complete one after another

steady_task_stream.py

from airflow.decorators import dag, task
from airflow.sensors.date_time import DateTimeSensor, DateTimeSensorAsync
from airflow.utils.dates import days_ago
from time import sleep


def tensec_taskfactory(i):

    @task(task_id=f"task_{i}")
    def wait():
        print(f"I am task {i}")
        sleep(10)

    return wait()


@dag(
    schedule_interval="@once",
    start_date=days_ago(1),
    default_args={"owner": "airflow"},
    catchup=False,
)
def steady_task_stream():

    prev = tensec_taskfactory(1)
    for i in range(2, 10):
        current = tensec_taskfactory(i)
        prev >> current
        prev = current

the_dag = steady_task_stream()