airflow - 气流返回列表索引超出范围

Question

当我对所有 Downstream-Recursive-Failed-Future 任务运行 clearAirflow 1.10.10

它返回列表索引超出范围错误。

随附的

DAG 定义

default_args = {
    'owner': 'I',
    'depends_on_past': False,
    'start_date': datetime(2020, 6, 1),
    'email': ['[e-mail] '],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 2,
    'retry_delay': timedelta(minutes=5),
    'on_failure_callback': slack_alert
}

with DAG(
        dag_id='aaa',
        default_args=default_args,
        description='my_desc',
        schedule_interval='0 * * * *'
        # schedule_interval=None
) as dag:

我不知道这是否是 Airflow 中的正常问题，但在升级到之前Airflow 2.0我想知道为什么会发生这种情况。

标签： airflow