(self, manager)
| 1238 | |
| 1239 | @flaky |
| 1240 | def test_large_group(self, manager): |
| 1241 | assert_ping(manager) |
| 1242 | |
| 1243 | c = group(identity.s(i) for i in range(1000)) |
| 1244 | res = c.delay() |
| 1245 | |
| 1246 | assert res.get(timeout=TIMEOUT) == list(range(1000)) |
| 1247 | |
| 1248 | def test_group_lone(self, manager): |
| 1249 | """ |
nothing calls this directly
no test coverage detected