()
| 18 | output_rows = [] |
| 19 | |
| 20 | def read_row(): |
| 21 | for row in reader: |
| 22 | self.assertEqual(len(row), 3) |
| 23 | output_rows.append(",".join(row)) |
| 24 | |
| 25 | run_concurrently(worker_func=read_row, nthreads=NTHREADS) |
| 26 | self.assertSetEqual(set(input_rows), set(output_rows)) |
nothing calls this directly
no test coverage detected