(self)
| 310 | req.on_ack.assert_called_with(req_logger, req.connection_errors) |
| 311 | |
| 312 | def test_on_failure_Reject_rejects(self): |
| 313 | einfo = None |
| 314 | try: |
| 315 | raise Reject() |
| 316 | except Reject: |
| 317 | einfo = ExceptionInfo(internal=True) |
| 318 | assert einfo is not None |
| 319 | req = self.get_request(self.add.s(2, 2)) |
| 320 | req.on_failure(einfo) |
| 321 | req.on_reject.assert_called_with( |
| 322 | req_logger, req.connection_errors, False, |
| 323 | ) |
| 324 | |
| 325 | def test_on_failure_Reject_rejects_with_requeue(self): |
| 326 | einfo = None |
nothing calls this directly
no test coverage detected