本文介绍了Apache Airflow:将任务延迟一段时间的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我正在尝试从DAG中的父任务执行5分钟后执行任务。
I am trying to execute a task after 5 minutes from the parent task inside a DAG.
DAG:任务1 ---->等待5分钟- --->任务2
DAG : Task 1 ----> Wait for 5 minutes ----> Task 2
如何在Apache Airflow中实现这一目标?
How can I achieve this in Apache Airflow? Thanks in advance.
推荐答案
您可以添加,在 Task1 之间的时间间隔为5分钟code>和
Task2
。
You can add a TimeDeltaSensor
with timedelta of 5 minutes between Task1
and Task2
.
这篇关于Apache Airflow:将任务延迟一段时间的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!