from airflow import DAG from airflow.operators.python import PythonOperator from datetime import datetime def hello(): print("hello world") with DAG( dag_id="test_simple", start_date=datetime(2026, 3, 1), schedule_interval="@daily", catchup=False ) as dag: PythonOperator(task_id="hello", python_callable=hello)