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