Спасибо 🙏

Всем привет. Что-то гуглеж сходу не дал ответа на вопрос "Можно ли в саб-даге внутри доставать список тасков и их xcom"
У меня был даг, в котором был кусок кода вида
```
tasks = [x.task_id for x in context['dag'].tasks if not isinstance(x, DummyOperator)]
```
Дальше я из этих тасков делал xcom_pull нужных мне данных.
Теперь я собрал этот даг и еще один похожий в sub-dag operator и когда я там выполняю такой кусок, мне приходят не таски внутри саб-дага, а сами sab-dag operators. В context что-то ничего похожего не увидел 🙁

Почему может фейлится даже простейший баш оператор? Есть 2 дага, в одном баш оператор выполняется нормально (просто date) , перенёс его в другой даг, в начало цепочки, сразу же фейлится

А что в логах?)

В логах ничего

может какой-то из компонентов не работает. проверьте логи шедулера и экзекьютора

Приветствую, вопрос следующего характера:
как сделать так чтобы каждый оператор в цепочке при фэйле мог отправить хук по вебу?

зайфелился отправил хук, с именем таски, дага и временем

могу слать в хэнгаутс от гугла, слака нету.

On_fail_callback у BaseOperator

пробовал) мне нужен бигквери или пайтон

кстати у меня почему-то на этом операторе прямо бесконечная отправка

BasOperator - базовый класс всех операторов. Напишите коллбек (детали ошибки можно из контекста взять), передайте его в default_args при создании дага, и будет счастье во всех тасках дага

Не понял) подробнее можно?

Надо функцию, принимающую контекст, написать, а не вызывать коллбек при создании оператора. Сейчас у вас  небось и без запуска дага в слак пишется.

ага

понял, буду смотреть как это сделать.
не могли бы указать раздел в доек или может статью на этот счет?

вот неплохо написано
https://livebook.manning.com/book/data-pipelines-with-apache-airflow/chapter-4/v-5/55