Ensure we can delete a task that's in the error queue.
(self)
| 992 | self._ensure_queues() |
| 993 | |
| 994 | def test_delete_failed_task(self): |
| 995 | """ |
| 996 | Ensure we can delete a task that's in the error queue. |
| 997 | """ |
| 998 | task = self.tiger.delay(exception_task) |
| 999 | Worker(self.tiger).run(once=True) |
| 1000 | self._ensure_queues(error={"default": 1}) |
| 1001 | task.delete() |
| 1002 | self._ensure_queues() |
| 1003 | |
| 1004 | def test_cancel_failed_task_2(self): |
| 1005 | """ |