Результаты поиска по запросу "airflow-scheduler"
Несколько строк кода было бы здорово.
виделаэто [https://stackoverflow.com/questions/46807297/airflow-externaltasksensor-gets-stuck] а такжеэто [https://stackoverflow.com/questions/52796647/airflow-external-sensor-gets-stuck-at-poking] вопросы по SO и внесены соответствующие ...
ОБНОВЛЕНИЕ ВОЗДУШНОГО ПОТОКА
ько что мучительно установил Airflow 1.10 благодарямой предыдущий пост здесь [https://stackoverflow.com/questions/51861453/airflow-1-10-installation-failing] , У нас работает один экземпляр ec2, наша очередь - AWS Elastic Cache Redis, а наша база ...
исправление дает нам имя хоста, а не IP-адрес. Мы должны использовать
я есть рабочая среда Airflow, использующая Airflow версии 1.9, которая работает на Amazon EC2-Instance. Мне нужно обновить до последней версии Airflow, который является 1.10. У меня есть возможность либо обновить версию 1.9, либо ...
, заставь его использовать стабильную ветку
ользую Airflow в кластерной среде, работающей на двух экземплярах AWS EC2. Один для мастера и один для работника. Рабочий узел периодически выдает эту ошибку при запуске «$ airflow worker»: [2018-08-09 16:15:43,553] {jobs.py:2574} WARNING - The ...
@TuanVu просто создайте учетную запись службы, и веб-сервер должен использовать ее, не указывая что-то еще
ользуюGoogle Cloud Composer [https://cloud.google.com/composer/](управляемый Airflow на Google Cloud Platform) с версией изображенияcomposer-0.5.3-airflow-1.9.0 и Python 2.7, и я столкнулся со странной проблемой: после импорта моих групп DAG ...
этот ответ
ил общий запрос на Airflow Можно ли запланировать файл dag на основе расписания другого файла dag. Например, если у меня есть 2 dag, а именно dag1 и dag2. Я пытаюсь увидеть, могу ли я запускать dag2 каждый раз, когда dag1 успешен, иначе dag2 не ...
Верно, но если вы сделаете это, и вы войдете в меню Job в пользовательском интерфейсе, вы увидите, что планировщик находится в режиме RUNNING. возможно принудительное закрытие не обновляет таблицу.
шный поток случайно не выполняет поставленные в очередь задачи, некоторые задачи даже не получают статус в очереди. Я продолжаю видеть ниже в журналах планировщика [2018-02-28 02:24:58,780] {jobs.py:1077} INFO - No tasks to consider ...
Или когда контекст доступен, например, в питоне из
аюсь запустить DAG с воздушным потоком, и мне нужно передать некоторые параметры для задач. Как прочитать строку JSON, переданную в качестве параметра --conf в командной строкеtrigger_dag команда, в файле DAG Python. например:airflow ...
звонки между двумя задачами.
ользую Airflow v1.8.1 и запускаю все компоненты (рабочий, веб, цветок, планировщик) на kubernetes & Docker. Я использую Celery Executor с Redis, и мои задачи выглядят так: (start) -> (do_work_for_product1) ├ -> (do_work_for_product2) ├ ...
а вот мой заказ
ользую Airflow 1.8.1 и хочу отправить результат запроса sql от PostgreOperator. Вот мои задачи: check_task = PostgresOperator( task_id='check_task', postgres_conn_id='conx', sql="check_task.sql", xcom_push=True, dag=dag) ...
Страница 1 из 2