python-3.x - 气流未正确调度

Question

我已将我的任务设置为每天运行，但程序却晚了一天运行，我想知道是否有答案？

 default_args ={
  'owner': 'airflow',
  'start_date' : datetime(year=2016,month=10,day=8),
  'depends_on_past': True,
  'email_on_failure': False,
  'email_on_retry': True,
  'retries:': 3,
  'retry_delay' :timedelta(minutes=2)}

我在 PST，所以即使调度程序使用 UTC，它也不应该影响它关闭 2 天的原因，因为 UTC 更快。和一天。例如，截至太平洋标准时间 10 月 18 日下午 6:00，计划任务的最后一次运行是 10 月 17 日，而不是 10 月 18 日。

Answer 1

Airflow 为前一个计划间隔安排 dags。

因此，带有 cron 计划的 dag@daily将收到execution_date（传递到已执行任务的上下文中）的2016/10/14 00:00:00when run on 2016/10/15 00:00:00。这个想法是，如果一个 dag 正在运行，2016/10/15 00:00:00它可能在 2016/10/14 00:00:00 到 2016/10/15 00:00:00 期间运行一些工作。