我正在使用Airflow 设置交叉依赖的DAGS。我有一个特定的使用案例,其中我的DAG B要求DAG A首先运行-但是,如果DAG A延迟足够长时间,DAG B仍应运行。因此,我本质上是在寻找一种方法来连接两个传感器之间的OR操作。假设DAG B需要每天下午5点运行,那么我将在代码中这样做: CURRENT_TIME = getCurrentTime()
if DAG A completed
我们正在尝试使用下面的git集线器作为引用来实现dag依赖项插件。https://github.com/ms32035/airflow-dag-dependencies**cannot import name 'conf' from 'airflow'** https://github.com/apache/airfl