Hello world DAG

interTwin-eu · Jan 11, 2024 · b4a4d32 · b4a4d32
1 parent 774cea1
commit b4a4d32
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/hello_world_dag.py b/hello_world_dag.py
@@ -0,0 +1,20 @@
+from airflow import DAG
+from airflow.operators.python import PythonOperator
+from datetime import datetime
+
+def helloWorld():
+    print(‘Hello World’)
+
+with DAG(dag_id="hello_world_dag",
+         start_date=datetime(2021,1,1),
+         schedule_interval="@hourly",
+         catchup=False) as dag:
+
+        task1 = PythonOperator(
+                task_id="hello_world",
+                python_callable=helloWorld)
+
+task1
+
+
+