python - Airflow dag 级别重试值会覆盖任务级别重试值吗？

Question

我注意到一个无主机错误与在任务文件夹中找不到日志相结合。我的任务的重试次数设置为 3。此外，dag 的重试次数设置为 1。在 dag 级别设置的重试值是否会覆盖任务重试？我注意到它在失败后没有重试。

Answer 1

没有 DAG 级别retries。您可能对default_args哪个可能包含retries并传递给 DAG 承包商感到困惑：

default_args = {
    'retries': 4
}
with DAG(
        dag_id='my_dag',
        default_args=default_args,
        ...
) as dag:
    t1 = BashOperator(
        task_id='print_date',
        bash_command='date',
    )
    t2 = BashOperator(
        task_id='sleep',
        bash_command='sleep 5',
        retries=3,
    )

这default_args是一个传递给任务的字典，它用作为 DAG 中的所有任务设置默认值的一种方式。在上面的示例中，t1将重试 4 次，因为它是默认值，default_args但t2将重试 3 次，因为它会覆盖默认值。