Size: a a a

2020 July 10

GG

George Gaál in Airflow
Но у тебя же внешний супервизор должен быть. Будь то системди или сам докер, которые будут его перезапускать в случае если он вышел
источник

L

Lexis in Airflow
че-то рестарт на выкл только ). Докеру как показать на шедулер? Вебсервер-то продолжает работать и healthcheck проходит (все в одном контейнере)
источник

L

Lexis in Airflow
может внутри контейнера настроить.... не подскажите направление куда гуглить?
источник

GK

Gleb Kozhaev in Airflow
Привет, есть ли что-то типа php operator? Скрипт, который таскает данные между базами на PHP, завернуть бы его в DAG. В гугл сходил, пока ничего не нашел)
источник

V

Vladislav in Airflow
Всем привет. Кто-нибудь настраивал на эйр ldap аутентификацию + доступ локальных юзеров? На данный момент эйр пускает пользователей ad, но не пускает локальных.
источник

ME

Max Efremov in Airflow
Gleb Kozhaev
Привет, есть ли что-то типа php operator? Скрипт, который таскает данные между базами на PHP, завернуть бы его в DAG. В гугл сходил, пока ничего не нашел)
Можно через шелл запускать
источник

GK

Gleb Kozhaev in Airflow
Max Efremov
Можно через шелл запускать
подходит, спасибо
источник

С

Сюткин in Airflow
PhpOperator
источник

С

Сюткин in Airflow
источник

АЖ

Андрей Жуков... in Airflow
жду перловый оператор
источник

PA

Panchenko Andrey in Airflow
гг
источник

AA

Anton Afonin in Airflow
Народ, а ни у кого не было проблем с mysql в качестве базы аирфлоу?
источник

AA

Anton Afonin in Airflow
У меня отработал таск, но падает с ошибкой
[2020-07-10 17:27:25,061] {bash_operator.py:130} INFO - Command exited with return code 0
[2020-07-10 17:27:25,069] {taskinstance.py:1145} ERROR - (_mysql_exceptions.IntegrityError) (1062, "Duplicate entry 'telegram_send_report-send_report_command-2020-07-10 13:40:04' for key 'PRIMARY'")
[SQL: INSERT INTO rendered_task_instance_fields (dag_id, task_id, execution_date, rendered_fields) VALUES (%s, %s, %s, %s)]
источник

ME

Max Efremov in Airflow
Были проблемы с SQLite :) С MySQL всё летает теперь 😁
источник

AA

Anton Afonin in Airflow
в момент записи в базу статуса таска, как я понимаю
источник

IS

Ihar Shurupau in Airflow
Всем привет! Кто-нибудь сталкивался с такой проблемой: после завершения таска/оператора и до запуска следующего (downstream) проходит довольно много времени (бывает 30 сек), в это время никакой полезной работы не выполняется (просто ожидание запуска следующего таска)
источник

AA

Anton Afonin in Airflow
Хм, таое ощущение, что перед записью обрезается до 64 символов запись
ERROR - (_mysql_exceptions.IntegrityError) (1062, "Duplicate entry 'telegram_send_report-send_regional_report_command-2020-07-10 15:' for key 'PRIMARY'")

И ожидаемо возникает ошбика с ключом
источник

ME

Max Efremov in Airflow
Ihar Shurupau
Всем привет! Кто-нибудь сталкивался с такой проблемой: после завершения таска/оператора и до запуска следующего (downstream) проходит довольно много времени (бывает 30 сек), в это время никакой полезной работы не выполняется (просто ожидание запуска следующего таска)
База какая?
источник

IS

Ihar Shurupau in Airflow
постгрес
источник

ME

Max Efremov in Airflow
У меня такое было со встроенной sqlite, на mysql уже секунд 10 стало
источник