[Hotfix] spark jobs name

FusRoman · Oct 5, 2023 · bc97e0d · bc97e0d
1 parent 4d92efd
commit bc97e0d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fink_mm/ztf_join_gcn.py b/fink_mm/ztf_join_gcn.py
@@ -510,9 +510,9 @@ def ztf_join_gcn(
     """
     logger = init_logging()
 
-    if DataMode.OFFLINE:
+    if mm_mode == DataMode.OFFLINE:
         job_name = "offline"
-    elif DataMode.STREAMING:
+    elif mm_mode == DataMode.STREAMING:
         job_name = "online"
 
     spark = init_sparksession(