Size: a a a

2021 October 14

ME

Max Efremov in Airflow
руками триггернуть всё, наверное
источник

R

Rustem in Airflow
Печалька)
источник

MM

Mikhail Mariufich in Airflow
ага, вот мы тут обсудили этот варик(
источник

MM

Mikhail Mariufich in Airflow
ну так-то наверно не сложно написать сенсор по логике как я хочу, отработала таска/dag не более чем timedelta. Просто охота, чтобы все эти ui фишки работали и лень писать/вникать))
источник

Э

Эльдар in Airflow
Привет! а есть какие-то варианты динамически определять ресурсы при запуске KubernetesPodOperator?
источник

VS

Vadim Sukhanov in Airflow
я давно как то залезал туда и по-моему я натыкался на веские причины такой реализации, но я щас уже прям деталей не помню, толи там не совсем очевидно было чекать даграны за которыми таска наблюдает толи еще что-то такое.

Если подумать то сенсор поудобнее там можно вцелом собрать, но это нужна задача=))


мы у себя пока оставили конфиг типа такого:

```
check_web_aggregation_is_done:
 type: check_airflow
 poke_interval: 3600
 dag_id: pod_web_sessions_00_02_A_A_A
 task_id: k8s_spark_web_aggregation_month
 months_delta: -1
 days_delta: 1

```

и пока вроде ок))
источник

MM

Mikhail Mariufich in Airflow
источник

Э

Эльдар in Airflow
тут параметры захардкожены в даге, а надо бы ресурсы из конфига вытянуть
источник

Э

Эльдар in Airflow
ресурсы не поддаются шаблонам jinja
источник

MM

Mikhail Mariufich in Airflow
окей, я думал оно под теплейтом
источник

MM

Mikhail Mariufich in Airflow
через вот это значит надо
источник

Э

Эльдар in Airflow
возможно, стоит попробовать. спасибо
источник
2021 October 15

n

noname in Airflow
Всем привет, может кто знает как удалить Даг через api? Airflow2
источник

I

Igor in Airflow
Так там вроде http delete прям на нужный путь дага
источник

I

Igor in Airflow
Я такое только на 1.x делал, там путь был что-то в духе /api/experimental/my_dag
источник

n

noname in Airflow
Угу это тоже нагуглил, но в 2 не работает(
источник

n

noname in Airflow
Ну всегда можно конечно в базу запрос кинуть, но не хотелось бы)
источник

MM

Mikhail Mariufich in Airflow
Видел, что в 2.2 добавили такое
источник

I

Igor in Airflow
А апи вообще включён?
источник

MM

Mikhail Mariufich in Airflow
источник