(self)
| 478 | assert rs1 == rs2 |
| 479 | |
| 480 | def test_get(self): |
| 481 | x = self.app.ResultSet([self.app.AsyncResult(t) for t in [1, 2, 3]]) |
| 482 | b = x.results[0].backend = Mock() |
| 483 | b.supports_native_join = False |
| 484 | x.join_native = Mock() |
| 485 | x.join = Mock() |
| 486 | x.get() |
| 487 | x.join.assert_called() |
| 488 | b.supports_native_join = True |
| 489 | x.get() |
| 490 | x.join_native.assert_called() |
| 491 | |
| 492 | @patch('celery.result.task_join_will_block') |
| 493 | def test_get_sync_subtask_option(self, task_join_will_block): |
nothing calls this directly
no test coverage detected