Method called by next processor whenever it has result for some test. This method shouldn't be called by anyone except next processor.
(self, test, result)
| 57 | raise NotImplementedError() |
| 58 | |
| 59 | def result_for(self, test, result): |
| 60 | """ |
| 61 | Method called by next processor whenever it has result for some test. |
| 62 | This method shouldn't be called by anyone except next processor. |
| 63 | """ |
| 64 | raise NotImplementedError() |
| 65 | |
| 66 | def heartbeat(self): |
| 67 | if self._prev_proc: |
no outgoing calls