#python #airflow
Вопрос:
Наш воздушный поток извлекает отчеты с веб-сайта. Мы отправляем параметры для отчета и используем датчик для определения его состояния. Иногда система сбрасывает отчеты, и датчик настроен так, чтобы распознавать, когда это происходит. Вместо сбоя, когда это происходит, есть ли способ, чтобы задача датчика сигнализировала планировщику, что сама по себе и ее родительская задача, отправляющая отчет, должны быть очищены, чтобы они могли работать снова?
Ответ №1:
С воздушным потоком 2.0 это возможно. Вы можете использовать API воздушного потока для очистки задачи и ее родительского элемента. Вызов API просто нуждается в списке задач для очистки, так что это очень просто. Документацию можно найти в разделе Документы в интерфейсе воздушного потока.
Комментарии:
1. Как вы «используете API воздушного потока»? Какой конкретный вызов API вы имеете в виду? Какова соответствующая часть документации? Я не думаю, что кто-то с подобной проблемой найдет в вашем ответе достаточно информации, чтобы решить ее.