(self)
| 1493 | self._ensure_queues() |
| 1494 | |
| 1495 | def test_custom_runner_class_batch_task(self): |
| 1496 | self.tiger.delay(batch_task, args=[1], runner_class=MyRunnerClass) |
| 1497 | self.tiger.delay(batch_task, args=[2], runner_class=MyRunnerClass) |
| 1498 | Worker(self.tiger).run(once=True) |
| 1499 | assert self.conn.get("task_args") == "1,2" |
| 1500 | self.conn.delete("task_args") |
| 1501 | self._ensure_queues() |
| 1502 | |
| 1503 | def test_mixed_runner_class_batch_task(self): |
| 1504 | """Ensure all tasks in a batch task must have the same runner class.""" |