Напиши простой DAG для Apache Airflow

Простой DAG можно описать через TaskFlow: две задачи и зависимость между ними. В примере ручной запуск и отсутствие внешних сервисов.

Пример для Airflow 3:

import pendulum
from airflow.sdk import dag, task

@dag(schedule=None, start_date=pendulum.datetime(2026, 1, 1, tz="UTC"),
     catchup=False)
def simple_pipeline():
    @task
    def prepare():
        return 2

    @task
    def calculate(value):
        print(value * 3)

    calculate(prepare())

simple_pipeline()

Вызов prepare при построении графа создаёт задачу, а calculate получает ссылку на её результат. Выполнение произойдёт после запуска DAG. schedule=None означает отсутствие автоматического расписания; start_date не запускает его сам по себе.

Источник: Документация Apache Kafka.