У меня есть даг воздушного потока с шестью задачами, все это используя gkepodoperator. Мой DAG имеет execution_timeout 1 час, но иногда задача 5 требуется больше времени, вызывая сбои. > • Время запуска DAG + 60 минут (общее окно выполнения)
• Вычтите время окончания задачи 4 (задача до задачи 5)
• оставьте 2-минутный буфер для выполнения задачи 6, чтобы завершить < /p>
Я попытался получить время начала DAG и время завершения задачи 4, используя xcom и dag_run.get_task_instance (), но он терпит неудачу внутри Gkepodoperator. < /p>
Там способ динамически вычислить и применить execution_timeout в самой задаче 5, не создавая дополнительную задачу?
Подробнее здесь: https://stackoverflow.com/questions/793 ... odoperator
