Я создал новый Dag со следующими аргументами: default_args = { 'owner':...

Есть три задачи «Сенсор» и один и тот же пул, для пула limit_sensor установлено значение 1, но...

У меня есть следующий код: def chunck_import(**kwargs): ... logging.info('Number of pages...

Мой рабочий процесс: Я получаю максимальный идентификатор заказа, который у нас сейчас есть, из...

Есть ли способ установить переменную в пользовательском интерфейсе Airflow, чтобы получить today

Привет, я новичок в Apache Airflow и использую on_failure_callback для обработки сбоя задачи.Но я...

Привет, я новичок в Apache Airflow, у меня есть зависимость: скажем, Задача A >> Задача B >> Задача...

Я хочу получить execution date - 2 months в формате YYYY-MM-DD HH:MM Это то, что я написал:...

У меня есть следующий код: file_name = gcs_export_uri_template + '/' + TABLE_PREFIX +...

Планировщик воздушного потока подбирает метки из правильной папки, как указано в файле airflow.cfg

У меня есть оператор в потоке воздуха: import_orders_op = MySqlToGoogleCloudStorageOperator(...

У меня есть следующий код: import_orders_op = MySqlToGoogleCloudStorageOperator(...

В Airflow я бы хотел, чтобы работа выполнялась в определенное время каждый день в часовом поясе, не...

У меня есть следующий рабочий процесс: Получить номер из MySqlOperator (динамический) Получить...

Я прочитал это Как использовать XCMS с воздушным потоком с MySqlOperator , и хотя он имеет похожее...

Я пытаюсь настроить конвейер воздушного потока, начиная с SensorOperator (то есть ожидая файлов)...

Я создаю динамический dag с настраиваемым числом исполнителей. Параметр «параллелизма», указанный в...

У меня есть Airflow DAG, в которой параллельно выполняется около 50 задач.Иногда я получаю это...

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

Документация 1.10.0 говорит, что я должен быть в состоянии сделать POST для / api /...

У меня каждый день запускается процесс Airflow со многими DAGS.Сегодня неожиданно ни один из DAGS...

Я хотел бы представить Apache Airflow команде среднего размера (1-10 человек).Как люди могут...

Синтаксис для передачи нескольких команд (состоящих из bash и python) параметру команды в...

Это мой код: default_args = { 'owner': 'airflow', 'depends_on_past':...

Я использую команду airflow cli backfill для ручного запуска некоторых заданий обратной засыпки....