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

Commit 185a321

Browse files
committed
fix tests
1 parent 4552aef commit 185a321

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

data_diff/info_tree.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ class SegmentInfo:
1818
rowcounts: Dict[int, int] = {}
1919
max_rows: int = None
2020

21-
def set_diff(self, schema: tuple[tuple[str, type]], diff: list[tuple[Any, ...]]):
21+
def set_diff(self, diff: list[tuple[Any, ...]], schema: tuple[tuple[str, type]] | None = None):
2222
self.diff_schema = schema
2323
self.diff = diff
2424
self.diff_count = len(diff)

data_diff/joindiff_tables.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ def _diff_segments(
206206
assert len(a_cols) == len(b_cols)
207207
logger.debug("Querying for different rows")
208208
diff = db.query(diff_rows, list)
209-
info_tree.info.set_diff(tuple(diff_rows.schema.items()), diff)
209+
info_tree.info.set_diff(diff, schema=tuple(diff_rows.schema.items()))
210210
for is_xa, is_xb, *x in diff:
211211
if is_xa and is_xb:
212212
# Can't both be exclusive, meaning a pk is NULL

0 commit comments

Comments
 (0)