(dd_read, pd_read, text, sep)
| 365 | ], |
| 366 | ) |
| 367 | def test_read_csv(dd_read, pd_read, text, sep): |
| 368 | with filetext(text) as fn: |
| 369 | f = dd_read(fn, blocksize=30, lineterminator=os.linesep, sep=sep) |
| 370 | assert list(f.columns) == ["name", "amount"] |
| 371 | # index may be different |
| 372 | result = f.compute(scheduler="sync").reset_index(drop=True) |
| 373 | assert_eq(result, pd_read(fn, sep=sep)) |
| 374 | |
| 375 | |
| 376 | def test_read_csv_convert_string_config(): |
nothing calls this directly
no test coverage detected