Update dags_airflow_ale_trainmod.py

interTwin-eu · Sep 16, 2024 · c8e471e · c8e471e
1 parent 3b30917
commit c8e471e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags_airflow_ale_trainmod.py b/dags_airflow_ale_trainmod.py
@@ -134,7 +134,7 @@ def check_response(response):
         # launch the Pod on the same cluster as Airflow is running on
         in_cluster=True,
         # launch the Pod in the same namespace as Airflow is running in
-        namespace="glitchflow",
+        namespace="airflow",
         # Pod configuration
         # name the Pod
         name="airflow_preprocessor",
@@ -169,4 +169,4 @@ def check_response(response):
 IniTrain>>sign_train>>chech_train_resp>>[next_sens,next_metrics]
 next_sens>>freeze
 [next_metrics,freeze]>>join_branch
-join_branch>>preproc
+join_branch>>preproc