from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime

def hello():
    print("Hello Airflow!")

with DAG("hello_world", start_date=datetime(2025, 9, 4), schedule_interval="@once") as dag:
    t1 = PythonOperator(task_id="hello", python_callable=hello)