本文介绍了安排DAG气流每5分钟运行一次的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我有一个DAG气流,现在它每小时运行一次(@hourly)。
是否可以每5分钟运行一次?
I have a DAG in airflow and for now it is running each hour (@hourly).Is it possible to have it running each 5 minutes ?
推荐答案
是的,这是我DAG的一个示例每5分钟运行一次:
Yes, here's an example of a DAG that I have running every 5 min:
dag = DAG(dag_id='eth_rates',
default_args=args,
schedule_interval='*/5 * * * *',
dagrun_timeout=timedelta(seconds=5))
schedule_interval
接受CRON表达式:
schedule_interval
accepts a CRON expression: https://en.wikipedia.org/wiki/Cron#CRON_expression
这篇关于安排DAG气流每5分钟运行一次的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!