我有 6 个 subdag。他们每个人都包含一个pool='crawler'需要大量资源的任务,所以我创建了一个crawler只有 1 个插槽的池。
pool='crawler'
crawler
当我运行 DAG 时,似乎绕过了池限制,同时执行了所有六个任务(如您从屏幕截图中看到的)。
如何强制使用的插槽成为<=可用插槽?
<=
airflow
airflow ×1