本文介绍了安排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表达式: en.wikipedia/wiki/Cron#CRON_expression
schedule_interval accepts a CRON expression: en.wikipedia/wiki/Cron#CRON_expression
更多推荐
安排DAG气流每5分钟运行一次
发布评论