Планирование DAG с помощью Python
Вы уже многое узнали о создании DAG, и теперь хотите настроить запуск конкретного DAG в определённый день недели в заданное время. Желательно включить эту информацию прямо в код — на случай, если коллеге понадобится переустановить DAG на другой сервер.
Объект dag из Airflow и необходимые методы datetime уже импортированы.
Это упражнение является частью курса
Введение в Apache Airflow на Python
Инструкции к упражнению
- Установите дату начала DAG: 1 ноября 2025 года.
- Используйте синтаксис cron, чтобы настроить расписание: каждую среду в 12:30.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()