Skip to content

Commit 440c43b

Browse files
committed
fix: pass key columns
Apologies, I only tested the case where --stats is passed.
1 parent ccdf54b commit 440c43b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

data_diff/format.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ def jsonify(
6060
t1_exclusive_rows, t2_exclusive_rows, diff_rows = _group_rows(diff_info, schema)
6161

6262
if not stats_only:
63-
rows = _make_rows_diff(t1_exclusive_rows, t2_exclusive_rows, diff_rows)
63+
rows = _make_rows_diff(t1_exclusive_rows, t2_exclusive_rows, diff_rows, key_columns)
6464

6565
summary = None
6666
if with_summary:
@@ -252,7 +252,8 @@ def _group_rows(
252252
def _make_rows_diff(
253253
t1_exclusive_rows: List[Dict[str, Any]],
254254
t2_exclusive_rows: List[Dict[str, Any]],
255-
diff_rows: List[Dict[str, Any]]
255+
diff_rows: List[Dict[str, Any]],
256+
key_columns: List[str],
256257
) -> RowsDiff:
257258
diff_rows_jsonified = []
258259
for row in diff_rows:

0 commit comments

Comments
 (0)