File tree Expand file tree Collapse file tree 1 file changed +19
-0
lines changed
Expand file tree Collapse file tree 1 file changed +19
-0
lines changed Original file line number Diff line number Diff line change 11import os
22import pathlib
33
4+ import pyarrow as pa
45import pytest
56from arro3 .core import Table
67
@@ -146,3 +147,21 @@ def test_vacuum_keep_versions():
146147 "part-00003-53f42606-6cda-4f13-8d07-599a21197296-c000.snappy.parquet" ,
147148 "part-00006-46f2ff20-eb5d-4dda-8498-7bfb2940713b-c000.snappy.parquet" ,
148149 }
150+
151+
152+ # https://github.com/delta-io/delta-rs/issues/3745
153+ def test_issue_3745 (tmp_path : pathlib .Path ):
154+ data = pa .Table .from_pydict (
155+ {
156+ "x" : pa .array (list (range (100 )), type = pa .int32 ()),
157+ }
158+ )
159+ write_deltalake (table_or_uri = tmp_path , data = data , mode = "append" )
160+
161+ table = DeltaTable (tmp_path )
162+ table .create_checkpoint ()
163+
164+ write_deltalake (table_or_uri = tmp_path , data = data , mode = "append" )
165+
166+ table = DeltaTable (tmp_path )
167+ table .vacuum ()
You can’t perform that action at this time.
0 commit comments