安排DAG气流每5分钟运行一次

本文介绍了安排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