У меня есть DAG с воздушным потоком, у которого BranchPythonOperator вызывает 1 из 4 SubDagOperators.Этот процесс работает нормально, но при увеличении масштаба каждого подпада, если заданный SubDagOperator не запущен и помечен как пропущенный, подзадачи в этом подзадаче постоянно помечаются как состояние running.
Как пометить задачи пропущенного субдага как skipped, а не постоянно running?