"""A manually triggered example DAG for Workflow engine version 3.x."""

import pendulum
from airflow.sdk import dag, task


@dag(
    dag_id="first_workflow",
    schedule=None,
    start_date=pendulum.datetime(2026, 1, 1, tz="UTC"),
    catchup=False,
)
def first_workflow():
    @task
    def prepare_data():
        return [10, 20, 30]

    @task
    def calculate_total(values):
        return sum(values)

    @task
    def report_total(total):
        print(f"Total: {total}")

    report_total(calculate_total(prepare_data()))


first_workflow()