Skip to content

Commit 57d4162

Browse files
committed
Refactor tests to use RecordBatchReader.from_stream instead of deprecated _import_from_c_capsule method
1 parent 759fb86 commit 57d4162

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

python/tests/test_dataframe.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1653,9 +1653,7 @@ def test_arrow_c_stream_to_table_and_reader(fail_collect):
16531653
assert table.schema == df.schema()
16541654
assert table.column("a").num_chunks == 2
16551655

1656-
reader = pa.RecordBatchReader._import_from_c_capsule(df.__arrow_c_stream__())
1657-
# alternatively, we could use
1658-
# reader = pa.RecordBatchReader.from_stream(df)
1656+
reader = pa.RecordBatchReader.from_stream(df)
16591657
assert isinstance(reader, pa.RecordBatchReader)
16601658
reader_table = pa.Table.from_batches(reader)
16611659
expected = pa.Table.from_batches([batch1, batch2])
@@ -2878,7 +2876,7 @@ def test_arrow_c_stream_interrupted():
28782876
"""
28792877
)
28802878

2881-
reader = pa.RecordBatchReader._import_from_c_capsule(df.__arrow_c_stream__())
2879+
reader = pa.RecordBatchReader.from_stream(df)
28822880

28832881
interrupted = False
28842882
interrupt_error = None

0 commit comments

Comments
 (0)