Я извлекаю категорию из таблицы метаданных и создаю динамические символы для каждой категории,...

В последние несколько дней я настраивал Apache Airflow как способ управления зависимостями на нашей...

Скажем, у нас есть два DAG, dag1 и dag2, они служат различным бизнес-требованиям. они совершенно не...

Я запланировал DAG с простой задачей bash запускать каждую 5-ю минуту: # bash_dag.py from airflow...

Всякий раз, когда я пытался запустить свою группу обеспечения доступности баз данных, он получает...

Постановка проблемы: запускает убер-даг.Sub-dag внутри него переходит в очередь.Через некоторое...

Я оцениваю Airflow как инструмент планирования заданий. 1) Можем ли мы создать несколько...

У меня есть 2 образца дагов, которые находятся в одном файле. dag = DAG(...

У меня есть DAG, которая запускается еженедельно каждый понедельник в 11:00.Он работал 13/05, был...

В моем DAG EMRStepSensor не работает во время просмотра шага.Это DAG dag >> инициализатор >>...

У меня 2 задания. В первом случае оператор python что-то вычисляет, а во втором я хочу использовать...

У меня airflow v1.8.2 и я пытался перейти на v1.10.3 После обновления я запускаю команду airflow...

Я хотел сгенерировать conn_id для spark_default . Я запускаю свой airflow на k8s, и я хотел...

Я пытаюсь вытащить xcom из подчиненного тега, но не могу себе позволить, поскольку он выдает...

Я новичок в Airflow, я хочу знать, смогу ли я выполнить скрипт на python, который вызывает airflow...

У меня есть две группы доступности баз данных, которые мне нужно запустить с Airflow 1.10.2 +...

У меня 8 заданий.Каждый набор представляет собой серию задач: задача1 >> задача2 >> задача3.задача...

У меня есть сценарий использования, где я внутри цикла for, и мне нужно динамически заполнить поля...

У меня есть список списков, скажем, import itertools test_list = list(itertools.permutations([1, 2,...

Я просто пытаюсь понять, есть ли способ ограничить продолжительность DAG в потоке воздуха.Например,...

Я изучаю AirFlow как механизм выполнения рабочих процессов. Мне нравится тот факт, что он очень...

В настоящее время я не вижу способов запустить прогон DAG, который уже создан, или перезапустить /...

В файле airflow.cfg я настроил значение min_file_process_interval равным 120 секундам. У даг был...

Я пытаюсь вычислить хеш для каждой задачи в потоке воздуха, используя комбинацию dag_id, task_id и...

Вот мой DAG: from airflow import DAG from airflow.operators.bash_operator import BashOperator from...