修改dag的start_date属性为早于计划的开始日期。例如,如果计划的开始日期是2021-01-01,则可以将start_date属性设置为2020-12-01,以确保在计划的开始日期之前有足够的缓冲时间。示例代码如下:
from airflow import DAG
from datetime import datetime, timedelta
default_args = {
'owner': 'airflow',
'start_date': datetime(2020, 12, 01),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval=timedelta(weeks=1)
)
# 添加任务