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