Сколько разных задач должно выполняться параллельно на одной машине, используя airflow...
Я использую Airflow для запуска заданий Spark в Google Cloud Composer.Мне нужно Создать кластер...
Я пытаюсь найти, есть ли файлы на удаленном сервере, которые соответствуют указанному шаблону....
Я использую BranchPythonOperator для создания веток в потоке воздуха.Мой пример использования - мне...
Я пытаюсь вставить в xcom значение с помощью ключа last_date в last_date_task, а затем вытащить его...