ME
Мб аирфлоу постарее?)
Size: a a a
2020 October 20
VN
Он ставился через csd пакет
DS
Привет всем!
Кто-то сталкивался с проблемкой?
Падает после 30 мнут работы. Загуглил, что такое может быть с редисом, но у нас ребит стоит в качестве брокера.
Кто-то сталкивался с проблемкой?
[2020-10-20 07:10:00,516] {local_task_job.py:156} WARNING - State of this instance has been externally set to failed. Taking the poison pill.
[2020-10-20 07:10:00,521] {helpers.py:325} INFO - Sending Signals.SIGTERM to GPID 2317Падает после 30 мнут работы. Загуглил, что такое может быть с редисом, но у нас ребит стоит в качестве брокера.
A
Taking the poison pill. 👍🏻
ME
Вроде в новых версиях поменяли этот чёрный юмор)
ME
DS
Вроде в новых версиях поменяли этот чёрный юмор)
В 1.10.12 поменяли? У меня 1.10.11, там ещё юморят ))
ME
В июне это был коммит в мастер. 9 числа. Над глянуть релизы с тех пор
ME
Хм, в 1.10.12 тоже осталось, странно
DS
Хм, в 1.10.12 тоже осталось, странно
По ходу это уже в 2.0 пойдет.
СГ
Ребят, подскажите, пожалуйста
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
E
Ребят, подскажите, пожалуйста
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
Поставь 1
I
Ребят, подскажите, пожалуйста
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
Выставил в даге start_date: days_ago(0) (использую from airflow.utils.dates import days_ago) и schedule_interval='25 4 * * *', но даг почему-то по расписанию каждый день не запускается, в чем может быть трабл?
от момента прочтения файлом этой строчки до start_date должен влезть хотя бы один период запуска
СГ
спасибо за ответы!
MF
Подскажите пожалуйста как перезапустить sсheduler с записью pid в файл? Пытаюсь airflow scheduler >> $AIRFLOW_HOME/scheduler.log --pid /home/airflow/airflow/airflow-scheduler.pid
Процесс запускается, а файл не появляется
Процесс запускается, а файл не появляется
PB
Добрый день!
Прошу подсказать, где можно почитать о способах отправки запросов через Experimental API?
Вещи наподобие этой принимать отказывается. 2 минуты бьется и потом отваливается с "connection timed out".
Прошу подсказать, где можно почитать о способах отправки запросов через Experimental API?
Вещи наподобие этой принимать отказывается. 2 минуты бьется и потом отваливается с "connection timed out".
выглядит норм, у себя запускаю вот так:
requests.post("http://exmpl.org/api/experimental/dags/exmpl-dag/dag_runs", json={"conf": {"param": 'value'}})
requests.post("http://exmpl.org/api/experimental/dags/exmpl-dag/dag_runs", json={"conf": {"param": 'value'}})
2020 October 21
NV
Привет, airflow отказывается видеть ChromeDriver для использования silenium, путь до драйвера прописан абсолютный, если этот скрипт выполнить просто в терминале, то все ок... Из-за чего может быть проблема?