Добавить hello.py

2025-09-04 07:43:51 +00:00
parent 2581f0a348
commit a4be372005
1 changed files with 9 additions and 0 deletions
--- a/hello.py
+++ b/hello.py
@@ -0,0 +1,9 @@
+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)