(file_fixture, options)
| 337 | pa.ipc.IpcReadOptions(use_threads=False), |
| 338 | ]) |
| 339 | def test_open_file_options(file_fixture, options): |
| 340 | file_fixture.write_batches() |
| 341 | source = file_fixture.get_source() |
| 342 | |
| 343 | reader = pa.ipc.open_file(source, options=options) |
| 344 | |
| 345 | reader.read_all() |
| 346 | |
| 347 | st = reader.stats |
| 348 | assert st.num_messages == 6 |
| 349 | assert st.num_record_batches == 5 |
| 350 | |
| 351 | |
| 352 | def test_open_file_with_wrong_options(file_fixture): |
nothing calls this directly
no test coverage detected