могу ли я сбросить start_date для существующего потока воздушных потоков без изменения его имени?В...

Во время работы планировщика воздушного потока, который использует mysql клиент from . import...

У меня есть несколько групп DAG, созданных в Airflow. Но я хочу запустить их все через некоторый...

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

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

Я исследовал это и в настоящее время придумываю стратегию с использованием Apache Airflow.Я все еще...

В более ранней версии Airflow 1.8 наша команда могла запускать группы DAG вручную, даже если для...

Я пытаюсь протестировать Airflow KubernetesPodOperator, следуя этому руководству https://kubernetes

Я настроил мою настройку Airflow для работы с systemd в соответствии с this .Это было замечательно...

Поэтому, прежде чем спросить об этом, я просмотрел документы и посмотрел на Разница между...

Я использую Airflow 1.9.0 на Celery Executor.У меня есть два сервера - один работает планировщик,...

Я пытаюсь установить airflow в моей среде python на сервере linux и в оболочке zsh. Я смог успешно...

У меня есть среда Airflow, работающая на Cloud Composer (3 n1-standard-1 узлы; версия образа:...

Я уже видел это и это вопросы по SO и внес изменения соответственно. Тем не менее, мой зависимый...

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

Я пытаюсь выполнить Spark jar на Dataproc, используя DataProcSparkOperator от Airflow .JAR...

Я новичок в использовании воздушного потока и что мне нужно сделать, это использовать MssqlHook или...

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

Я только что установил Cloud Composer Environment в Python 3 и версии образа Composer composer-1.4

Я использую TriggerDagRunOperator, для которого у меня есть контроллер Dag и целевой Dag....

После некоторых интенсивных исследований становится ясно, что можно изменить поток воздуха [core]...

Я использую BranchPythonOperator для создания веток в потоке воздуха.Мой пример использования - мне...

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

У меня проблема с воздушным потоком при работе его на 24-часовой машине на EC2. Должен отметить,...

Я знаю, что, например, если у нас есть несколько файлов sql в папке данных, мы можем установить...