vin*_*sce 5 airflow
我有 6 个 subdag。他们每个人都包含一个pool='crawler'需要大量资源的任务,所以我创建了一个crawler只有 1 个插槽的池。
pool='crawler'
crawler
当我运行 DAG 时,似乎绕过了池限制,同时执行了所有六个任务(如您从屏幕截图中看到的)。
如何强制使用的插槽成为<=可用插槽?
<=
kax*_*xil 6
从源代码:
SubDagOperator 不支持气流池。因此资源可以被 SubdagOperators 消耗
归档时间:
7 年,1 月 前
查看次数:
3737 次
最近记录: