Size: a a a

2020 October 02

DS

Dmitry Samoylov in Airflow
Что влияет на ограничение кол-во выполняемых тасков в DAG'е. Например, такая ситуация. Есть даг - 700 тасок. В каждой таске - очень долгий запрос на 30+ минут. Даг вынесен в отдельный pool, а также повешена настройка concurrency=3. Но в итоге в базе вижу 7 созданных конннектов от каждой таски и в airflow 7 запущенных тасок...
источник

DM

Dan M. in Airflow
я где-то читал, что он не успевает вычитать весь файл, возможно, опция в конфиге с сериализацией дагов может помочь
источник

DS

Dmitry Samoylov in Airflow
Dan M.
я где-то читал, что он не успевает вычитать весь файл, возможно, опция в конфиге с сериализацией дагов может помочь
спасибо, попробую покопать в этом направлении
источник

IL

Ilya Lozhkin in Airflow
Всем привет, может кто то знает фреймворк для работы с моделями на питоне, но с возможностью визуального накидывания задач?

Клиент зашел, выбрал какие таски ему нужны и все поехало в реальном времени крутиться
источник

IL

Ilya Lozhkin in Airflow
типа такого, только не для airflow
источник

ME

Max Efremov in Airflow
на стримсеты похоже)
источник

NA

Nikita Anshakov in Airflow
Ilya Lozhkin
типа такого, только не для airflow
А как эта штука называется ?
источник

IL

Ilya Lozhkin in Airflow
Nikita Anshakov
А как эта штука называется ?
источник

IL

Ilya Lozhkin in Airflow
Фронт генерит json, потом по нему идет кодген в даги airflow
источник

AA

Anton Alekseev in Airflow
источник

IL

Ilya Lozhkin in Airflow
Похоже на то, только надо opensource и что бы на своем железе хостить
источник

IL

Ilya Lozhkin in Airflow
https://github.com/selinon/selinon
https://github.com/AustralianSynchrotron/Lightflow

есть вот 2 движка, но фронт нужно делать 🙁
источник

А

Анатоли in Airflow
подскажите в конфиге airflow который копирую в docker контейнер
https://medium.com/@xnuinside/quick-guide-how-to-run-apache-airflow-cluster-in-docker-compose-615eb8abd67a
подключаю вот так через строку
sql_alchemy_conn = postgresql+psycopg2://$your_db_user:$your_db_password@$your_postgres_db_host:$postgres_port/$db_name

так вот ворос  your_postgre   это имя контейнера docker?  какое имя хоста или имя сервиса?
services:
 postgres
источник

GB

Georgy Borodin in Airflow
Анатоли
подскажите в конфиге airflow который копирую в docker контейнер
https://medium.com/@xnuinside/quick-guide-how-to-run-apache-airflow-cluster-in-docker-compose-615eb8abd67a
подключаю вот так через строку
sql_alchemy_conn = postgresql+psycopg2://$your_db_user:$your_db_password@$your_postgres_db_host:$postgres_port/$db_name

так вот ворос  your_postgre   это имя контейнера docker?  какое имя хоста или имя сервиса?
services:
 postgres
your_db_user – логин от постгреса
your_db_password – пароль
your_postgres_db_host – где хостится постгрес (ip, домен, название сервиса в docker-compose)
postgres_port – порт постгреса
db_name – бд в постгрес для airflow
источник

А

Анатоли in Airflow
делаю один в один по статье
при поднятии получаю
dockairflow_scheduler_1 exited with code 1
dockairflow_webserver_1 exited with code 1
с  ошибками python
поменял только имя контейнера так как такой уже используется
источник

GB

Georgy Borodin in Airflow
Анатоли
делаю один в один по статье
при поднятии получаю
dockairflow_scheduler_1 exited with code 1
dockairflow_webserver_1 exited with code 1
с  ошибками python
поменял только имя контейнера так как такой уже используется
Сванговать сложно, в чём дело, в особенности без текста ошибок)
источник

А

Анатоли in Airflow
у меня строка COPY ./airflow.cfg /usr/local/airflow/airflow.cfg не отрабатывает
источник

А

Анатоли in Airflow
захожу в сам контейнер а там docker exec -it postgres1 bash
а там файла airflow.cfg нет вроде по этому пути /usr/local
источник

GB

Georgy Borodin in Airflow
Анатоли
у меня строка COPY ./airflow.cfg /usr/local/airflow/airflow.cfg не отрабатывает
Если бы оне не срабатывала, контейнеры бы не поднимались
источник

А

Анатоли in Airflow
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: connection
источник