Как совместить операторов Airflow?

Почти все мои группы DAG будут иметь подмножество повторяющихся операторов. И из-за моего варианта использования очень хорошо получается создавать новые операторы-оболочки, которые объединяют несколько операторов, чтобы уменьшить шаблон.

У меня вопрос, как их объединить?

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

postgres_operator_task >> slack_operator_task -> query_then_slack_operator_task

Источник

1 ответ

Проверьте идею подтегов.
Ресурсы:

Источник
Другие вопросы по тегам