Результаты поиска по запросу "airflow-scheduler"
@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 1.10 благодарямой предыдущий пост здесь [https://stackoverflow.com/questions/51861453/airflow-1-10-installation-failing] , У нас работает один экземпляр ec2, наша очередь - AWS Elastic Cache Redis, а наша база ...
этот ответ
ил общий запрос на Airflow Можно ли запланировать файл dag на основе расписания другого файла dag. Например, если у меня есть 2 dag, а именно dag1 и dag2. Я пытаюсь увидеть, могу ли я запускать dag2 каждый раз, когда dag1 успешен, иначе dag2 не ...
Несколько строк кода было бы здорово.
виделаэто [https://stackoverflow.com/questions/46807297/airflow-externaltasksensor-gets-stuck] а такжеэто [https://stackoverflow.com/questions/52796647/airflow-external-sensor-gets-stuck-at-poking] вопросы по SO и внесены соответствующие ...
Или когда контекст доступен, например, в питоне из
аюсь запустить DAG с воздушным потоком, и мне нужно передать некоторые параметры для задач. Как прочитать строку JSON, переданную в качестве параметра --conf в командной строкеtrigger_dag команда, в файле DAG Python. например:airflow ...
исправление дает нам имя хоста, а не 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 ...
Верно, но если вы сделаете это, и вы войдете в меню Job в пользовательском интерфейсе, вы увидите, что планировщик находится в режиме RUNNING. возможно принудительное закрытие не обновляет таблицу.
шный поток случайно не выполняет поставленные в очередь задачи, некоторые задачи даже не получают статус в очереди. Я продолжаю видеть ниже в журналах планировщика [2018-02-28 02:24:58,780] {jobs.py:1077} INFO - No tasks to consider ...
а вот мой заказ
ользую 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) ...
Я также установил новые dags по умолчанию, чтобы они были приостановлены в моем airflow.cfg
могу увидеть журналы, прикрепленные к задачам из интерфейса Airflow: [/imgs/8VLEc.png] Настройки журнала, связанные с файлом airflow.cfg: remote_base_log_folder =base_log_folder ...
Страница 1 из 2