Хорошо, структура воздушного потока сделана так, что schedule_interval
установлен на уровне DAG. Это означает, что вы можете установить время, когда вся группа DAG начнет выполнение, но вы не можете указать другое время выполнения для задачи .
Решение, если у вас есть три отдельные задачи, которые не зависят друг от друга, состоит в создании трех различных групп доступности баз данных и планировании их на эти три разных времени.
Если вместо этого временная зависимость task_2
и task_3
не так важна, но вы заботитесь только о том, что выполняются одна за другой , вы действительно можете установить зависимости между задачами так, чтобы task_2
запускается всегда после завершения task_1
, а task_3
запускается всегда после завершения task_2
. Чтобы установить зависимости, вы можете использовать очень удобный синтаксис (при условии, что ваши задачи были назначены переменным task_1
, task_2
, task_3
):
task_1 >> task_2 >> task_3
Вы можете обратиться к Официальный Airflow документация для получения дополнительной информации.
TL; DR: Вы не можете запланировать запуск отдельных задач с разными указанными c разами, поскольку вы можете установить только одно время. общий прогон DAG один.