Воздушный поток: текущий сбой задачи, как пометить нисходящий поток как пропущенный или нет статуса - PullRequest
0 голосов
/ 27 сентября 2019

У меня есть группа доступности базы данных, где последним заданием является EmailOperator для отправки информационного электронного сообщения об успехе.Когда предыдущая (предшествующая EmailOperator) задача завершается неудачно и помечается как State: failed, последняя задача (EmailOperator) затем отображается желтым цветом в пользовательском интерфейсе up_for_retry, но отмечается в журналах как State: upstream_failed.

Почему задача с upstream_failed назначается на up_for_retry или, по крайней мере, в этом конкретном случае?Есть ли способ убедиться, что это не up_for_retry и визуализировать его как skipped или no_status.

Вот мои текущие default_args настройки ...

default_args = {
    'owner': '<myname>',
    'depends_on_past': True,
    'start_date': datetime(2019, 9, 27),
    'email': ['<myemail>'],
    'email_on_failure': True,
    #'email_on_retry': False,
    'retries': 0
    #'retry_delay': timedelta(minutes=15)
}

enter image description here

...