14 lines
337 B
Python
14 lines
337 B
Python
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) |