从函数返回应在Airflow中按顺序运行的任务列表

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime

def task1():
    # 任务1的逻辑
    pass

def task2():
    # 任务2的逻辑
    pass

def task3():
    # 任务3的逻辑
    pass

def task4():
    # 任务4的逻辑
    pass

default_args = {
    'start_date': datetime(2022, 1, 1)
}

with DAG('task_sequence_dag', default_args=default_args, schedule_interval=None) as dag:
    task_list = [task1, task2, task3, task4]

    for task_func in task_list:
        task = PythonOperator(
            task_id=task_func.__name__,
            python_callable=task_func,
            provide_context=True
        )

        if task_func == task_list[0]:
            # 第一个任务没有依赖，直接添加到DAG中
            task
        else:
            # 后续任务通过设置依赖关系来保证顺序
            task_list[task_list.index(task_func)-1] >> task