diff --git a/src/transformers/data_transformer.py b/src/transformers/data_transformer.py index 3b10045..9d553e5 100644 --- a/src/transformers/data_transformer.py +++ b/src/transformers/data_transformer.py @@ -402,6 +402,13 @@ class DataTransformer: # Store measurements with node number as key consolidated_measurements[str(node_num)] = node_measurements + # Log consolidation to help debug + if len(group_rows) > 1: + logger.debug( + f"Consolidating node {node_num} for unit={key[0]}, tool={key[1]}, " + f"timestamp={key[3]}: {len(node_measurements)} measurement categories" + ) + # Use the row with minimum id as template for other fields min_id_row = min(group_rows, key=lambda r: r["idElabData"]) # Use the row with maximum id for the consolidated row ID (for proper resume)