From 7a8e9d4db12327b2f28410258c96da4e1a935108 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arturo=20Filast=C3=B2?= Date: Tue, 10 Sep 2024 15:42:56 -0400 Subject: [PATCH] Add custom prefix to analysis schedule filter --- oonipipeline/src/oonipipeline/temporal/schedules.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/oonipipeline/src/oonipipeline/temporal/schedules.py b/oonipipeline/src/oonipipeline/temporal/schedules.py index a41e2dfa..acb5f6ac 100644 --- 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