В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Airflow

1103 membersпожаловаться на группу
2021 January 29

OI

Oleg Ilinsky in Airflow
Aлексей Mатюхин
Добрый день. Подскажите, пожалуйста, есть ли в airflow какой-то идентификатор джоба, или задания. Чтобы можно было его в базу записать, и определить, каким таском были загружены данные?
dag_run_id
источник
13:13пожаловаться#1

OI

Oleg Ilinsky in Airflow
https://airflow.apache.org/docs/apache-airflow/stable/macros-ref.html
источник
13:14пожаловаться#2

OI

Oleg Ilinsky in Airflow
можно использовать как макрос {{ dag_run }} хоть прям в sql запросе
источник
13:14пожаловаться#3

AM

Aлексей Mатюхин... in Airflow
Oleg Ilinsky
можно использовать как макрос {{ dag_run }} хоть прям в sql запросе
Спасибо!🙏
источник
13:17пожаловаться#4
2021 January 31

А

Анастасия in Airflow
Привет! А как правильно искать корень проблемы 'python callable' param must be callable?
источник
00:55пожаловаться#5

А

Андрей in Airflow
Анастасия
Привет! А как правильно искать корень проблемы 'python callable' param must be callable?
Функцию туда надо передать. В примерах с питоновскими тасками смотрите
источник
00:59пожаловаться#6

А

Анастасия in Airflow
Андрей
Функцию туда надо передать. В примерах с питоновскими тасками смотрите
Я знаю, что проблема появляется только при добавлении последнего таска, при этом саму функцию я уже обрезала до одного принта
источник
01:10пожаловаться#7

А

Анастасия in Airflow
Андрей
Функцию туда надо передать. В примерах с питоновскими тасками смотрите
источник
01:10пожаловаться#8

А

Андрей in Airflow
контекст еще надо передать
источник
01:11пожаловаться#9

А

Андрей in Airflow
provide_context=True
источник
01:13пожаловаться#10

А

Анастасия in Airflow
Андрей
provide_context=True
Оно в default_args стоит
источник
01:20пожаловаться#11

DY

Dmitry Yakimets in Airflow
Тут неопределенность: название оператора и функции одинаковые.
источник
10:06пожаловаться#12

А

Анастасия in Airflow
Dmitry Yakimets
Тут неопределенность: название оператора и функции одинаковые.
Спасибо! Без цикла такая штука работает нормально - я и не подумала
источник
11:17пожаловаться#13

D

Dmitry in Airflow
Всем привет! У меня вот такой вопрос: я хочу по бранч оператору выбирать одну из тасок, а потом продолжать дальше с обязательным выполнением таски "pwd". Но такска скипается, потому что одна из предыдущих из бранч оператора тоже скипнулась. Что сделать чтобы это исправить?)
источник
22:51пожаловаться#14

D

Dmitry in Airflow
Дамми оператор с триггер рулом?
источник
22:56пожаловаться#15

ME

Max Efremov in Airflow
Просто триггер рул сделать не олл саксес, а одного чтобы хватало
источник
22:58пожаловаться#16

D

Dmitry in Airflow
Но нужен дамми оператор? У самого bash оператора триггер рула нет или есть?
источник
23:00пожаловаться#17

ME

Max Efremov in Airflow
Оно у всех есть, они же операторы
источник
23:03пожаловаться#18

ME

Max Efremov in Airflow
one_success просто поставить и всё
источник
23:04пожаловаться#19

D

Dmitry in Airflow
Max Efremov
one_success просто поставить и всё
Ага, работает! Спасибо)
источник
23:06пожаловаться#20