我正在尝试执行一个只需要运行一次的 dag。所以我将 dag 执行间隔设置为“@once”。但是,我收到此链接中提到的错误 - https://issues.apache.org/jira/browse/AIRFLOW-1400
现在我正在尝试传递准确的执行日期,如下所示:
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2017,11,13),
'email': ['airflow@airflow.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(seconds=5)
}
dag = DAG(
dag_id='dagNameTest', default_args=default_args, schedule_interval='12 09 13 11 2017',concurrency=1)
这是抛出错误:
File "/usr/lib/python2.7/site-packages/croniter/croniter.py", line 543, in expand
expr_format))
CroniterBadCronError: [12 09 13 11 2017] is not acceptable, out of range
谁能帮忙解决这个问题。
谢谢, 阿琼
最佳答案
“星期几”位置是 2017 年。尝试 12 09 13 11 * .您正在尝试在“schedule interval”字段中设置“日期”。所以从技术上讲,这将安排每年一次。您可以这样运行它,当它完成后,停用 DAG。
关于python-2.7 - 如何安排 dag 运行一年中一个月的特定时间。即,一次,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47261255/