Skip to content

Commit

Permalink
bump deltalake (#18)
Browse files Browse the repository at this point in the history
  • Loading branch information
xbrianh authored Sep 10, 2024
1 parent c144c7c commit 1e5cc78
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion requirements-dev.txt
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
build
pandas
deltalake
deltalake>=0.19.2
ruff-lsp
mypy
gcsfs
Expand Down
2 changes: 1 addition & 1 deletion tests/test_compatibility.py
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ def test_optimize(self):
num_start_rows = xdl.to_pyarrow_table().to_pandas().shape[0]
xdl = xdl.delete((((pc.field("float64") > pc.scalar(0.9)) | (pc.field("cats") == pc.scalar("A")))))
deltalake.DeltaTable(dt_loc).delete("float64 > 0.9 or cats == 'A'")
deltalake.DeltaTable(dt_loc).optimize()
deltalake.DeltaTable(dt_loc).optimize.compact()

with self.subTest("should have actually deleted rows"):
self.assertLess(xdl.to_pyarrow_table().to_pandas().shape[0], num_start_rows)
Expand Down

0 comments on commit 1e5cc78

Please sign in to comment.