From ac881b3a3c3aedf9f45a999e9ff4a99e02e35923 Mon Sep 17 00:00:00 2001 From: browo097302 Date: Fri, 4 Oct 2024 14:02:10 +0100 Subject: [PATCH] Change name of second __splink__cluster_count_row_numbered query, prevent duplicate table name conflict --- splink/internals/cluster_studio.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/splink/internals/cluster_studio.py b/splink/internals/cluster_studio.py index 76d4da678f..19534c384d 100644 --- a/splink/internals/cluster_studio.py +++ b/splink/internals/cluster_studio.py @@ -233,7 +233,7 @@ def _get_cluster_id_of_each_size( where row_num <= {rows_per_partition} """ - pipeline.enqueue_sql(sql, "__splink__cluster_count_row_numbered") + pipeline.enqueue_sql(sql, "__splink__cluster_count_row_numbered_2") df_cluster_sample_with_size = linker._db_api.sql_pipeline_to_splink_dataframe( pipeline )