У меня есть dag, где я использую список нижеприведенных операторов
- TriggerDagrunoperator-для запуска другого dag
- ExternalTaskSensor-Получить статус сработавшего dag
Мой вариант использования: скажем, например, если весь поток завершился успешно, и я обнаружил некоторую проблему с обработкой данных между ними. Я хочу повторно выполнить задание на эту конкретную дату выполнения с момента выдачи. Я очистил вниз по течению, и это делает работу заново. Но TriggerDagrunoperator завершается ошибкой из-за проблемы ниже.
airflow.exceptions.DagRunAlreadyExists: Идентификатор запуска triggered_: уже существует для идентификатора dag *
Я хочу очистить это, и мне нужно повторно запустить dag дляэта конкретная дата исполнения. Есть ли лучший способ сделать это?