При запуске airflow backfill --mark_success с соответствующей датой начала и окончания и dag_id.Даг...
Я недавно столкнулся с этой неприятной ошибкой, когда apply_defaults декоратор от Airflow...
Я использую Airflow 1.9.0.И мы поняли, что планировщик иногда застревает в ожидании завершения...
Я пытаюсь установить airflow 1.10.0 на сервере AWS EC2.Я получаю сообщение об ошибке ниже. Моя...
Я запускаю поток воздуха в virtualenv как пользователь_A с LocalExecutor .Когда я использую...
Другие сообщения по этому / похожему вопросу не помогли мне.Так что я боюсь, что я упускаю из виду...
По умолчанию каждый DAG имеет несколько кнопок (Trigger Dag, Delete Dag и т. Д.) В главном...
Я создал группу обеспечения доступности баз данных, где некоторая конфигурация определена следующим...
У меня есть черта, похожая на эту: with DAG(..., concurrency=3) as dag: important = [ op1, op2, op3...
Я создал контейнер, который копирует файл return.json в /airflow/xcom/return.json При запуске этого...
Я создал BranchPythonOperator, который вызывает 2 задачи в зависимости от условия, например:...
Я хотел бы знать, есть ли простой API-вызов, который я могу сделать, чтобы вывести список всех...
Я пытаюсь написать несколько SQL-операторов в JdbcOperator и не знаю, как использовать шаблон; Или...
Я попытался вызвать еще один dag с некоторыми параметрами в TriggerDagRunOperator, но в сработавшем...
Есть ли способ настроить Airflow таким образом, чтобы он считывал метаданные из другого источника...
Я выполнил следующую тестовую команду: airflow test events {task_name_redacted} 2018-12-12 ... и...
У меня есть DAG, которая запускается по расписанию, и задачи внутри нее находят файл в пути,...
Я новичок в воздушном потоке Apache, у нас есть несколько заданий, которые на сервере Windows, мы...
Я использую рабочие потоки воздуха как экземпляры на Mesos, в настоящее время с LocalExecutor во...
Я изучаю основы Airflow (apache-airflow == 1.10.1, MacBook OSX) и не могу понять фактическое...
Я пытаюсь установить apache-airflow (pip install apache-airflow), и мне нужно использовать...
Я установил airflow 2.0 на своем локальном Mac, используя PostgresSQL для sql_alchemy_conn. Мои...
Я пытаюсь установить воздушный поток (распределенный режим) в WSL, я получил настройку веб-сервера...
Я пытаюсь создать соединение Hive в потоке воздуха, чтобы указать конкретную базу данных. Я...
Я познакомился с функциями программирования воздушного потока, попробовав множество образцов. Что...