Skip to content

Commit

Permalink
fix other test
Browse files Browse the repository at this point in the history
  • Loading branch information
wjones127 committed Oct 5, 2023
1 parent 164e4f3 commit 0bf6e65
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions python/tests/test_delete.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,9 @@ def test_delete_a_partition(tmp_path: pathlib.Path, sample_data: pa.Table):
def test_delete_some_rows(existing_table: DeltaTable):
old_version = existing_table.version()

expr = ~pc.field("utf8").isin(["0", "1"])
expected_table = existing_table.to_pyarrow_table().filter(expr)
existing = existing_table.to_pyarrow_table()
mask = pc.invert(pc.is_in(existing["utf8"], pa.array(["0", "1"])))
expected_table = existing.filter(mask)

existing_table.delete(predicate="utf8 in ('0', '1')")

Expand Down

0 comments on commit 0bf6e65

Please sign in to comment.