From 48b9f96427bf05b99ac2695811f4109d8bb19aeb Mon Sep 17 00:00:00 2001 From: gitea_admin Date: Sat, 24 Jan 2026 15:41:19 +0000 Subject: [PATCH] Ajouter hello_world.py ajout example basique dag --- hello_world.py | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 hello_world.py diff --git a/hello_world.py b/hello_world.py new file mode 100644 index 0000000..4d57eb0 --- /dev/null +++ b/hello_world.py @@ -0,0 +1,29 @@ +from airflow.decorators import dag, task +from datetime import datetime + +# 1. On définit le DAG avec le décorateur @dag +@dag( + dag_id="hello_world_taskflow", + start_date=datetime(2026, 1, 1), + schedule_interval="@daily", # Se lance tous les jours à minuit + catchup=False, # Ne rattrape pas les exécutions passées + tags=["exemple"], +) +def hello_world_dag(): + + # 2. On définit une première tâche + @task + def get_name(): + return "Collaborateur" + + # 3. On définit une deuxième tâche qui reçoit un paramètre + @task + def say_hello(name): + print(f"Hello {name} ! Bienvenue sur Airflow 2026.") + + # 4. On définit l'ordre d'exécution (le workflow) + user_name = get_name() + say_hello(user_name) + +# 5. On instancie le DAG +hello_world_dag()