Add custom prefix to analysis schedule filter

ooni · Sep 10, 2024 · 7a8e9d4 · 7a8e9d4
1 parent 78484a0
commit 7a8e9d4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/oonipipeline/src/oonipipeline/temporal/schedules.py b/oonipipeline/src/oonipipeline/temporal/schedules.py
@@ -76,7 +76,7 @@ async def list_existing_schedules(
             f"{custom_prefix}{OBSERVATIONS_SCHED_PREFIX}-{filter_id}"
         ):
             schedule_id_map_list.observations.append(sched.id)
-        elif sched.id.startswith(f"{ANALYSIS_SCHED_PREFIX}-{filter_id}"):
+        elif sched.id.startswith(f"{custom_prefix}{ANALYSIS_SCHED_PREFIX}-{filter_id}"):
             schedule_id_map_list.analysis.append(sched.id)
 
     return schedule_id_map_list