小编Fad*_*ura的帖子

假设我们有两个 DAG，dag1 和 dag2，它们服务于不同的业务需求。它们完全无关。但 dag1 更重要的是尽早完成它。
为简单起见，它们都只有一项任务并且每天运行。

在 dag1 落后于计划 2 或 3 天的情况下，我想确保 dag1 运行并首先完成其 dag_runs，即 dag1 在 dag2 能够继续之后是最新的。

我尝试过 priority_weight 但它不适用于不同的 dag。

我需要一种将来自两个不同 dag 的任务放在同一个队列中并实现 DAG 级别优先级的方法。