Skip to content

Commit ac4f71e

Browse files
committed
test: patch tests temporarily
1 parent bafa82b commit ac4f71e

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

tests/utils/test_manifest.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -515,6 +515,14 @@ def test_rolling_manifest_writer(
515515
PartitionField(source_id=2, field_id=2, transform=IdentityTransform(), name="tpep_pickup_datetime"),
516516
spec_id=demo_manifest_file.partition_spec_id,
517517
)
518+
519+
# The tests are using `PyArrowFileIO` where `OutputStream` is implemented as `pyarrow.lib.BufferedOutputStream`
520+
# this is just to show the tests passing if `pyarrow.lib.BufferedOutputStream` would implement the
521+
# new `OutputStream` protocol that includes a `__len__` method
522+
from pyiceberg.avro.file import AvroOutputFile
523+
AvroOutputFile.__len__ = lambda self: self.output_stream.tell()
524+
525+
518526
with TemporaryDirectory() as tmpdir:
519527

520528
def supplier() -> Generator[ManifestWriter, None, None]:

0 commit comments

Comments
 (0)