(self)
| 536 | terminate=False, timeout=None) |
| 537 | |
| 538 | def test_revoke_from_resultset(self): |
| 539 | self.app.control.revoke = Mock(name='revoke') |
| 540 | uuids = [uuid() for _ in range(10)] |
| 541 | r = self.app.GroupResult( |
| 542 | uuid(), [self.app.AsyncResult(x) for x in uuids]) |
| 543 | r.revoke() |
| 544 | self.app.control.revoke.assert_called_with( |
| 545 | uuids, |
| 546 | connection=None, reply=False, signal=None, |
| 547 | terminate=False, timeout=None) |
| 548 | |
| 549 | def test_after_fork_clears_mailbox_pool(self): |
| 550 | amqp = Mock(name='amqp') |
nothing calls this directly
no test coverage detected