当使用Airflow调度任务时,CRON表达式在运行DAG时可能会出现问题。如果CRON表达式不起作用,请确认是否遵循正确的CRON格式,并尝试使用datetime.timedelta对象来定义您的任务间隔。
示例代码:
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
default_args = {
'owner': 'airflow',
'start_date': datetime(2021, 1, 1),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval='30 20 * * 2,3'
)
task1 = BashOperator(
task_id='task1',
bash_command='echo "Hello World"',
dag=dag
)
在上面的示例中,我们定义了一个DAG,它运行在CRON格式“30 20 * * 2,3”下。此表达式具有以下含义:在星期二和星期三的下午8点30分运行该DAG。
确保您的CRON表达式正确,并按照此示例格式定义您的定时任务。
上一篇:AirflowDag不按预期运行
下一篇:AirflowDAG步骤依赖关系