(self, test)
| 29 | self.buffer = deque() |
| 30 | |
| 31 | def next_test(self, test): |
| 32 | if test.is_heavy: |
| 33 | if self.n_heavy < self.max_heavy: |
| 34 | # Enough space to send more heavy tests. Check if the test is not |
| 35 | # filtered otherwise. |
| 36 | used = self._send_test(test) |
| 37 | if used: |
| 38 | self.n_heavy += 1 |
| 39 | return used |
| 40 | else: |
| 41 | # Too many tests in the pipeline. Buffer the test and indicate that |
| 42 | # this test didn't end up in the execution queue (i.e. test loader |
| 43 | # will try to send more tests). |
| 44 | self.buffer.append(test) |
| 45 | return False |
| 46 | else: |
| 47 | return self._send_test(test) |
| 48 | |
| 49 | def result_for(self, test, result): |
| 50 | if test.is_heavy: |
nothing calls this directly
no test coverage detected