hello world
This commit is contained in:
14
dags/test_simple.py
Normal file
14
dags/test_simple.py
Normal file
@@ -0,0 +1,14 @@
|
||||
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)
|
||||
Reference in New Issue
Block a user