Различное поведение в зависимости от того, запускается ли DAG вручную или нет - PullRequest
0 голосов
/ 30 апреля 2020

Я знаю, что Airflow различает ручные и запланированные триггеры группы обеспечения доступности баз данных - структура их идентификатора различна, а также интерфейс пользователя в древовидном представлении показывает обведенный круг для одного, но не другого.

У меня есть группа обеспечения доступности баз данных, которая использует Python, вызываемую как on_failure_callback, для выдачи предупреждения о сбое. Теперь я хочу изменить эту группу обеспечения доступности баз данных таким образом, чтобы она выдавала один тип оповещения при неудачном запуске , запускаемого вручную, при одновременном отправлении другого оповещения при запуске планировщиком.

I это можно сделать, просто проанализировав строку в {{ execution_date }}. Тем не менее, это кажется хакерским. Есть ли флаг, который я могу проверить вместо этого?

1 Ответ

1 голос
/ 30 апреля 2020

Кажется очень связанным с этим вопросом: Могу ли я программно определить, была ли группа DAG Airflow запланирована или запущена вручную?

Похоже, вы можете посмотреть run_id и проанализировать его вместо этого, что может быть немного лучше.

...