(self, test)
| 44 | self._unpack_result(pool_result) |
| 45 | |
| 46 | def next_test(self, test): |
| 47 | if self.is_stopped: |
| 48 | return False |
| 49 | |
| 50 | test_id = test.procid |
| 51 | cmd = test.get_command(self.ctx) |
| 52 | self._tests[test_id] = test, cmd |
| 53 | |
| 54 | outproc = self._outproc_factory(test) |
| 55 | self.ctx.pool.add_jobs([Job(test_id, cmd, outproc, test.keep_output)]) |
| 56 | |
| 57 | return True |
| 58 | |
| 59 | def result_for(self, test, result): |
| 60 | assert False, \ |
nothing calls this directly
no test coverage detected