Merge pull request #2447 from browo097302/master

Change name of second __splink__cluster_count_row_numbered query, prevent table name conflict
moj-analytical-services · Oct 14, 2024 · 96e6602 · 96e6602
2 parents c985367 + bd1d108
commit 96e6602
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
     )