Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 71f726a

Browse files
committed
Don't calculate sum/avg for key columns
1 parent aac0ebf commit 71f726a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

data_diff/joindiff_tables.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,11 @@ def _collect_stats(self, i, table_seg: TableSegment):
235235

236236
# Metrics
237237
col_exprs = merge_dicts(
238+
{
239+
f"min_{c}": min_(this[c]),
240+
f"max_{c}": max_(this[c]),
241+
}
242+
if c in table_seg.key_columns else
238243
{
239244
f"sum_{c}": sum_(this[c]),
240245
f"avg_{c}": avg(this[c]),

0 commit comments

Comments
 (0)