Skip to content

Commit

Permalink
change format
Browse files Browse the repository at this point in the history
  • Loading branch information
Ubuntu committed Oct 16, 2024
1 parent d77b911 commit 4573ea2
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions tools/distpartitioning/dataset_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -560,9 +560,7 @@ def get_dataset(
if next_chunk is None:
break

next_table = pyarrow.Table.from_batches(
[next_chunk]
)
next_table = pyarrow.Table.from_batches([next_chunk])
src_ids.append(next_table["f0"].to_numpy())
dst_ids.append(next_table["f1"].to_numpy())
elif (
Expand Down

0 comments on commit 4573ea2

Please sign in to comment.