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

Commit cb31d5e

Browse files
committed
base calls to _bisect_and_diff_segments_root should always execute first
Otherwise the info_tree is missing key ranges for the majority of execution
1 parent 9f656aa commit cb31d5e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

data_diff/diff_tables.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -302,7 +302,7 @@ def _bisect_and_diff_tables(self, table1: TableSegment, table2: TableSegment, in
302302

303303
ti = ThreadedYielder(self.max_threadpool_size, self.yield_list)
304304
# Bisect (split) the table into segments, and diff them recursively.
305-
ti.submit(self._bisect_and_diff_segments_root, ti, btable1, btable2, info_tree)
305+
ti.submit(self._bisect_and_diff_segments_root, ti, btable1, btable2, info_tree, priority=999)
306306

307307
# Now we check for the second min-max, to diff the portions we "missed".
308308
# This is achieved by subtracting the table ranges, and dividing the resulting space into aligned boxes.
@@ -326,7 +326,7 @@ def _bisect_and_diff_tables(self, table1: TableSegment, table2: TableSegment, in
326326

327327
for p1, p2 in new_regions:
328328
extra_tables = [t.new_key_bounds(min_key=p1, max_key=p2) for t in (table1, table2)]
329-
ti.submit(self._bisect_and_diff_segments_root, ti, *extra_tables, info_tree)
329+
ti.submit(self._bisect_and_diff_segments_root, ti, *extra_tables, info_tree, priority=999)
330330

331331
return ti
332332

0 commit comments

Comments
 (0)