(self)
| 1509 | self._ensure_queues(error={"batch": 2}) |
| 1510 | |
| 1511 | def test_permanent_error(self): |
| 1512 | task = self.tiger.delay(exception_task, runner_class=MyErrorRunnerClass) |
| 1513 | Worker(self.tiger).run(once=True) |
| 1514 | assert self.conn.get("task_id") == task.id |
| 1515 | self.conn.delete("task_id") |
| 1516 | self._ensure_queues(error={"default": 1}) |
| 1517 | |
| 1518 | def test_eager_task(self): |
| 1519 | self.tiger.config["ALWAYS_EAGER"] = True |