任务开始时间找不到解决方案。我有代码,找不到我错了。
当我运行DAG时,分别为25.03、26.03、27.03。任务已经完成,但是今天(28.03)的任务没有在6:48开始。
我尝试使用cron表达式,钟摆,日期时间和结果相同。当地时间(UTC + 3)和气流时间(UTC)不同。我尝试在“开始日期”或“时间表间隔”中使用每次(本地,空气流量),但没有结果。
使用:Ubuntu,Airflow 1.9.0版和本地执行程序。
emailname = Variable.get('test_mail')
l_start_date = datetime(2018, 3, 25, 6, 48)
l_schedule_interval = '@daily'
WORKFLOW_DEFAULT_ARGS = {
'owner': 'owner',
'depends_on_past': True,
'start_date': l_start_date,
'email': emailname,
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retries_delay': timedelta(minutes=1),
}
# initialize the DAG
dag = DAG(
dag_id='test_dag_mail',
default_args=WORKFLOW_DEFAULT_ARGS,
schedule_interval=l_schedule_interval,
start_date=l_start_date,
)
Run Code Online (Sandbox Code Playgroud)