python-2.7 - 如何安排 dag 运行一年中一个月的特定时间。即,一次

标签 python-2.7 airflow apache-airflow airflow-scheduler

我正在尝试执行一个只需要运行一次的 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/

相关文章:

python - 有没有办法在 Apache Airflow 中将 RBAC 与 LDAP 结合起来?

airflow - 我可以通过向 Airflow 中的运算符添加更多 CPU 来提高处理速度吗?

airflow - 哎呀……清除 Airflow 中失败的任务状态时出现 AttributeError

python - 从另一个字典列表中减去字典列表中的值

python-2.7 - Python 中的 Tix 教程

airflow - 使用 KubernetesPodOperator 创建 sidecar

每月的日期和时间的 Airflow DAG 调度

python - 如何将 websocket push api 输出写入文本文件?

python - 可靠的 : You should rebuild using libgmp >= 5 to avoid timing attack vulnerability

运行 Airflow 命令行后,sqlite3 引发错误