(self)
| 839 | assert job.acknowledged |
| 840 | |
| 841 | def test_on_failure_WorkerLostError(self): |
| 842 | |
| 843 | def get_ei(): |
| 844 | try: |
| 845 | raise WorkerLostError('do re mi') |
| 846 | except WorkerLostError: |
| 847 | return ExceptionInfo() |
| 848 | |
| 849 | job = self.xRequest() |
| 850 | exc_info = get_ei() |
| 851 | job.on_failure(exc_info) |
| 852 | self.app.set_current() |
| 853 | assert self.mytask.backend.get_status(job.id) == states.FAILURE |
| 854 | |
| 855 | self.mytask.ignore_result = True |
| 856 | exc_info = get_ei() |
| 857 | job = self.xRequest() |
| 858 | job.on_failure(exc_info) |
| 859 | assert self.mytask.backend.get_status(job.id) == states.PENDING |
| 860 | |
| 861 | def test_on_failure_acks_late_reject_on_worker_lost_enabled(self): |
| 862 | try: |
nothing calls this directly
no test coverage detected