Size: a a a

2021 April 25

SC

Stanislav Chernov in Airflow
Привет!
А как правильно обновить 2.0.1 на 2.0.2 ?
И есть ли список изменений ?
источник

SC

Stanislav Chernov in Airflow
список изменений нашёл
источник

SC

Stanislav Chernov in Airflow
источник

K

Konstantin in Airflow
Не будем изменять традиции ) начало положено. спасибо. будут вопросы вернусь )
источник
2021 April 26

SC

Stanislav Chernov in Airflow
Скажите, а ни у кого не наблюдается проблем с производительностью когда используется много TimeDeltaSensor ?
У меня в одном даге их 31, а всего тасков 127.
Если включаем его - то ппц, моментально load average > 50.0 становится
Через минут 15 сервер оживает, и часть тасков сразу в фэйле, так как CeleryExecutor по таймауту отвалился
источник

SC

Stanislav Chernov in Airflow
Причём, на rabbit-mq это было ..
Сейчас поменяли на redis - более-менее стал шустрее оживать... за 2-3 минуты
источник

Igor  Master in Airflow
У нас по памяти проседал sensor когда мы поставили ему мод reschedule и не поставили poke_interval, а вместо этого почему то указывали reschedule_interval
источник

R

Rustam in Airflow
Подскажите пожалуйста, можно ли заставить эйрфлоу запускать определенные таски в разное время?
К примеру, даг запускается на ежедневной основе, но я хочу, чтобы один из операторов выполнялся только лишь раз в неделю: есть ли возможность прописать schedule_interval для этого оператора отдельно?
источник

AS

Alexander Saykov in Airflow
Хороший вопрос. Я бы тоже хотел знать на него ответ :)
источник

M

MIKHAIL in Airflow
Всем привет! Интересует такой вопрос, у меня даги уже второй день в состоянии scheduled. Не могу найти в чём причина их не выполнения, кто-либо  сталкивался с такой проблемой?
источник

YV

Yuliya Volkova in Airflow
Нет, ты можешь сделать флаг - если флаг был поставлен меньше чем неделю назад - скипаем таску.
источник

YV

Yuliya Volkova in Airflow
В качестве флага - xcom от этой же таски, например
источник

R

Rustam in Airflow
Спасибо, буду разбираться )
источник

А

Александр in Airflow
Можно попробовать поковырять через сабдаг, с start и end date https://airflow.apache.org/docs/apache-airflow/stable/concepts.html#subdags
источник

VB

Vitali Bartniak in Airflow
Добрый день,
может кто сталкивался с такой проблемой:
есть airflow в докере, пытаюсь отправить письмо с использованием EmailOperator, в конфиге [smtp] параметры настроены, но при выполнении оператора получаю ошибку ERROR - [Errno 101] Network is unreachable.
Хотя smtp сервер рабочий и с виртуалки, на которой докер с аирфлоу, пингуется.
источник

YV

Yuliya Volkova in Airflow
их никогда нельзя было запускать по расписанию отличному от основного ДАГа
источник

YV

Yuliya Volkova in Airflow
хотя может что-то поменялось с 1.10.3, я давно их использовала
источник

MF

Mihail F in Airflow
Здравствуйте. После перезапуска AF словил такое:

sqlalchemy.exc.OperationalError: (psycopg2.OperationalError) server closed the connection unexpectedly
This probably means the server terminated abnormally
before or while processing the request.


Подскажите пожалуйста как фиксить?
источник

BP

Beni Paz in Airflow
Может порт закрыт?
источник

ME

Max Efremov in Airflow
а телнетится?
источник