Пометить задачу воздушного потока с пользовательским статусом

Question

Я пытался создать даг, у которого есть только одна задача.Могу ли я пометить задачу с требуемым статусом, например, пропущенным или без статуса?

Требование: Обычно я буду смотреть на корзину s3 каждую минуту, и если будут доступны файлы, я выполню некоторую обработку.в противном случае я просто уйду.Я хочу видеть эту видимость в пользовательском интерфейсе.так.Я пытался пометить статус задачи как пропущенный.

это правильный способ сделать?у нас есть какой-нибудь другой способ достичь этого

Спасибо

Answer 1

Если вы хотите пометить задачу как пропущенную, вы можете поднять AirflowSkipException.При поднятии выполнение задачи будет остановлено, и задача будет помечена как пропущенная.

В этом примере "Воздушный поток" для DummySkipOperator демонстрирует оператора, который помечается как пропущенный путем повышениявышеуказанное исключение.