From 7cee8c106773a84fe8e6b4c0e14ed6989bcbc858 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Far=C3=ADas=20Santana?= Date: Thu, 30 Jan 2025 14:32:50 +0100 Subject: [PATCH] fix(delete-persons): Use tuple to compose query (#28080) --- posthog/temporal/delete_persons/delete_persons_workflow.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/posthog/temporal/delete_persons/delete_persons_workflow.py b/posthog/temporal/delete_persons/delete_persons_workflow.py index e927042e2abba..7cc4b63aa565b 100644 --- a/posthog/temporal/delete_persons/delete_persons_workflow.py +++ b/posthog/temporal/delete_persons/delete_persons_workflow.py @@ -63,7 +63,7 @@ async def mogrify_delete_queries_activity(inputs: MogrifyDeleteQueriesActivityIn logger = get_internal_logger() select_query = SELECT_QUERY.format( - person_ids_filter=f"AND id IN ({inputs.person_ids})" if inputs.person_ids else "" + person_ids_filter=f"AND id IN {inputs.person_ids}" if tuple(inputs.person_ids) else "" ) delete_query_person_distinct_ids = DELETE_QUERY_PERSON_DISTINCT_IDS.format(select_query=select_query) delete_query_person_override = DELETE_QUERY_PERSON_OVERRIDE.format(select_query=select_query) @@ -116,7 +116,7 @@ async def delete_persons_activity(inputs: DeletePersonsActivityInputs) -> tuple[ logger = get_internal_logger() select_query = SELECT_QUERY.format( - person_ids_filter=f"AND id IN ({inputs.person_ids})" if inputs.person_ids else "" + person_ids_filter=f"AND id IN {inputs.person_ids}" if tuple(inputs.person_ids) else "" ) delete_query_person_distinct_ids = DELETE_QUERY_PERSON_DISTINCT_IDS.format(select_query=select_query) delete_query_person_override = DELETE_QUERY_PERSON_OVERRIDE.format(select_query=select_query)