Я установил экземпляр воздушного потока на eks и установил AIRFLOW__CORE__EXECUTOR=KubernetesExecutor. Когда у dag есть только задачи, но нет подпадара, то каждый модуль динамически создается для каждой задачи и работает нормально, но когда у меня есть dag с несколькими подпадами, он не выполняет подзадачу, и вместо этого первая задача внутри первого подпада остается в состояние очереди.
После того, как я установил AIRFLOW__CORE__EXECUTOR=LocalExecutor и при создании субдага я установил executor=KubernetesExecutor(), он работает нормально, а задачи внутри субдагов выполняются в отдельных модулях. Но я не знаю, получу ли я такую же силу от KubernetesExecutor или нет.
Заранее спасибо.