(file_fixture)
| 214 | |
| 215 | @pytest.mark.pandas |
| 216 | def test_file_read_pandas(file_fixture): |
| 217 | frames = [batch.to_pandas() for batch in file_fixture.write_batches()] |
| 218 | |
| 219 | file_contents = pa.BufferReader(file_fixture.get_source()) |
| 220 | reader = pa.ipc.open_file(file_contents) |
| 221 | result = reader.read_pandas() |
| 222 | |
| 223 | expected = pd.concat(frames).reset_index(drop=True) |
| 224 | assert_frame_equal(result, expected) |
| 225 | |
| 226 | |
| 227 | def test_file_pathlib(file_fixture, tmpdir): |
nothing calls this directly
no test coverage detected