Airflow ExternalTaskSensor с различным интервалом планировщика
В настоящее время у меня есть две группы DAG: DAG_A и DAG_B. Оба работают с schedule_interval=timedelta(days=1) У DAG_A есть задача 1, выполнение которой обычно занимает...
airflow-scheduler
Воздушный поток с использованием Cronitier
Я пытаюсь использовать Cronitier, чтобы запланировать задание, которое будет выполняться ежемесячно каждые 2 вторника. Я пробовал ниже Это мой частичный сценарий. из croniter импорт croniter...
Сбой при монтировании тома оператора модуля Kubernetes, в результате чего модули не создаются
Я пытаюсь преобразовать задание искровой отправки, которое настраивалось через файл yaml, в dag воздушного потока и запустить его через воздушный поток. Задание не выполняется, когда...
что означает Execution_date и backfill в воздушном потоке
Я новичок в воздушном потоке и пытаюсь понять, что execution_date означает в контексте воздушного потока. Я прочитал страницу руководства из документации по воздушному потоку, в...