小编Ник*_*ний的帖子

Apache Airflow中调度程序间隔和启动时间的工作不正确

任务开始时间找不到解决方案。我有代码,找不到我错了。

当我运行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)

python python-3.x airflow airflow-scheduler

2
推荐指数
1
解决办法
1744
查看次数

标签 统计

airflow ×1

airflow-scheduler ×1

python ×1

python-3.x ×1