fix: make all entity_values unique by appending row index to support bulk_create with ignore_conflicts

fix: unique entity_value fallback to prevent bulk_create ignore_conflicts from skipping duplicates
fix: fallback entity value when column is empty to ensure all UMAP profiles are saved
2026-07-22 23:17:09 +08:00 · 2026-07-22 23:14:00 +08:00 · 2026-07-22 23:11:32 +08:00
1 changed files with 2 additions and 3 deletions
@@ -986,9 +986,8 @@ def _run_clustering_pipeline(run, store, entity_ds_id, feature_columns, algorith
                        profiles = []
                        cr_cache = {}
                        for i, row in enumerate(df_umap.iter_rows(named=True)):
-                            ev = str(row.get(ent_col, ''))
-                            if not ev:
-                                continue
+                            ev = str(row.get(ent_col, '')) or 'entity'
+                            ev = f'{ev}_{i}'
                            lbl = labels_list[i] if i < len(labels_list) else -1
                            cache_key = f'{run.id}_{lbl}'
                            if cache_key not in cr_cache:
Author	SHA1	Message	Date
PM-pinou	035d22b234	fix: make all entity_values unique by appending row index to support bulk_create with ignore_conflicts	2026-07-22 23:17:09 +08:00
PM-pinou	0d92a5a170	fix: unique entity_value fallback to prevent bulk_create ignore_conflicts from skipping duplicates	2026-07-22 23:14:00 +08:00
PM-pinou	c1db7ad7eb	fix: fallback entity value when column is empty to ensure all UMAP profiles are saved	2026-07-22 23:11:32 +08:00