При использовании обратной засыпки воздушного потока с LocalExecutor доступные слоты пула, похоже, игнорируются. Например, ниже. Я знаю, что это было поднято несколько лет назад, но это все еще проблема?
Pool Slots Used Slots Queued Slots
workerpool0 3 0 0
workerpool2 3 12 0
Пробовал перезапускать веб-сервер, планировщик.
Определение пула в BashOperator.
BashOperator(
task_id='sleep.%d'%i,
bash_command='sleep %d'%(i+5),
retries=3,
pool='workerpool2',
dag=dag)
Я ожидаю, что размер пула будет равен 3, но он фактически назначает 12 заданий, как указано выше?