(self, *args)
| 712 | |
| 713 | class FailingQueue(Queue): |
| 714 | def __init__(self, *args): |
| 715 | self.fail_next_put = False |
| 716 | self.fail_next_get = False |
| 717 | Queue.__init__(self, *args) |
| 718 | def _put(self, item): |
| 719 | if self.fail_next_put: |
| 720 | self.fail_next_put = False |