Как повторно запустить даг, который уже был выполнен с помощью оператора TriggerDagrun? ⇐ Python

[Anonymous]

У меня есть даг, где я использую список операторов ниже

• TriggerDagrunoperator — для запуска другого дага
• ExternalTaskSensor — получение статуса запущенного dag

Мой вариант использования:
Скажем, например, если Весь поток завершился успешно, и я обнаружил некоторую проблему с промежуточной обработкой данных. Я хочу повторно запустить задание для этой конкретной даты выполнения с момента выдачи. Я очистил нисходящий поток, и задание можно запустить повторно. Но TriggerDagrunoperator завершается сбоем из-за приведенной ниже проблемы.

airflow.Exceptions.DagRunAlreadyExists: идентификатор запуска триггера_: уже существует для идентификатора дага

Я хочу это очистить, и мне нужно еще раз запустить даг для этой конкретной даты выполнения. Есть ли лучший способ добиться этого?

Подробнее здесь: https://stackoverflow.com/questions/583 ... unoperator