(self, manager)
| 194 | |
| 195 | @pytest.mark.xfail(raises=TimeoutError, reason="Task is timeout") |
| 196 | def test_group_results_in_chain(self, manager): |
| 197 | # This adds in an explicit test for the special case added in commit |
| 198 | # 1e3fcaa969de6ad32b52a3ed8e74281e5e5360e6 |
| 199 | c = ( |
| 200 | group( |
| 201 | add.s(1, 2) | group( |
| 202 | add.s(1), add.s(2) |
| 203 | ) |
| 204 | ) |
| 205 | ) |
| 206 | res = c() |
| 207 | assert res.get(timeout=TIMEOUT / 10) == [4, 5] |
| 208 | |
| 209 | def test_chain_of_chain_with_a_single_task(self, manager): |
| 210 | sig = signature('any_taskname', queue='any_q') |