在Airflow中,可以使用retry_delay
参数来设置任务的重试延迟。该参数指定了任务在失败后的重试延迟时间。
下面是一个示例代码,演示如何在Airflow中设置任务的重试延迟:
from datetime import timedelta
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1),
'retries': 3,
'retry_delay': timedelta(minutes=5)
}
def my_task():
# 这是你的任务代码
# 如果任务失败,它将在每次重试之间等待5分钟
pass
with DAG('retry_delay_example', default_args=default_args, schedule_interval='@daily') as dag:
start = DummyOperator(task_id='start')
task = PythonOperator(task_id='my_task', python_callable=my_task)
end = DummyOperator(task_id='end')
start >> task >> end
在上面的示例中,我们创建了一个名为retry_delay_example
的DAG,并设置了默认的重试延迟为5分钟。在任务my_task
中,如果任务失败,它将会在每次重试之间等待5分钟。
你可以根据需要调整retry_delay
参数的值,以满足你的业务需求。