We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 57d4162 commit d66d496Copy full SHA for d66d496
python/tests/test_dataframe.py
@@ -1698,11 +1698,8 @@ def test_arrow_c_stream_schema_selection(fail_collect):
1698
capsule_new = ctypes.pythonapi.PyCapsule_New
1699
capsule_new.restype = ctypes.py_object
1700
capsule_new.argtypes = [ctypes.c_void_p, ctypes.c_char_p, ctypes.c_void_p]
1701
- schema_capsule = capsule_new(ctypes.c_void_p(address), b"arrow_schema", None)
1702
1703
- reader = pa.RecordBatchReader._import_from_c_capsule(
1704
- df.__arrow_c_stream__(schema_capsule)
1705
- )
+ reader = pa.RecordBatchReader.from_stream(df, schema=requested_schema)
1706
1707
assert reader.schema == requested_schema
1708
0 commit comments