Skip to content

Commit

Permalink
fix: test expectations
Browse files Browse the repository at this point in the history
  • Loading branch information
roeap committed Jan 15, 2024
1 parent 2d9a5ea commit 27d9712
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion python/tests/test_fs.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,11 +77,11 @@ def test_read_simple_table_from_remote(s3_localstack):
assert dt.to_pyarrow_table().equals(pa.table({"id": [5, 7, 9]}))

expected_files = [
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
"part-00000-c1777d7d-89d9-4790-b38a-6ee7e24456b1-c000.snappy.parquet",
"part-00001-7891c33d-cedc-47c3-88a6-abcfb049d3b4-c000.snappy.parquet",
"part-00004-315835fe-fb44-4562-98f6-5e6cfa3ae45d-c000.snappy.parquet",
"part-00007-3a0e4727-de0d-41b6-81ef-5223cf40f025-c000.snappy.parquet",
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
]

assert dt.files() == expected_files
Expand Down
4 changes: 2 additions & 2 deletions python/tests/test_table_read.py
Original file line number Diff line number Diff line change
Expand Up @@ -552,11 +552,11 @@ def test_read_multiple_tables_from_s3(s3_localstack):
for path in ["s3://deltars/simple", "s3://deltars/simple"]:
t = DeltaTable(path)
assert t.files() == [
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
"part-00000-c1777d7d-89d9-4790-b38a-6ee7e24456b1-c000.snappy.parquet",
"part-00001-7891c33d-cedc-47c3-88a6-abcfb049d3b4-c000.snappy.parquet",
"part-00004-315835fe-fb44-4562-98f6-5e6cfa3ae45d-c000.snappy.parquet",
"part-00007-3a0e4727-de0d-41b6-81ef-5223cf40f025-c000.snappy.parquet",
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
]


Expand All @@ -572,11 +572,11 @@ def read_table():
b.wait()
t = DeltaTable("s3://deltars/simple")
assert t.files() == [
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
"part-00000-c1777d7d-89d9-4790-b38a-6ee7e24456b1-c000.snappy.parquet",
"part-00001-7891c33d-cedc-47c3-88a6-abcfb049d3b4-c000.snappy.parquet",
"part-00004-315835fe-fb44-4562-98f6-5e6cfa3ae45d-c000.snappy.parquet",
"part-00007-3a0e4727-de0d-41b6-81ef-5223cf40f025-c000.snappy.parquet",
"part-00000-2befed33-c358-4768-a43c-3eda0d2a499d-c000.snappy.parquet",
]

threads = [ExcPassThroughThread(target=read_table) for _ in range(thread_count)]
Expand Down

0 comments on commit 27d9712

Please sign in to comment.