1

我有一个 dag,我想多次运行 30 次。但是气流可以一次并行执行 16 个 dag 运行。假设一个 dag run 需要更长的时间来执行,那么在等待的 14 个 dag run 中,我想先运行第 10 个 dag run。气流中有什么方法可以实现这一目标吗?我知道我们可以通过一些方法为不同的 dag 和任务设置优先级权重。但我想为 dag 运行分配优先权重。

简而言之,我正在寻找一种方法来为同一 dag 的多个 dag 运行设置优先级

谢谢。

4

0 回答 0