| 449 | |
| 450 | @flaky |
| 451 | def test_chain_of_nine_chords(self, manager): |
| 452 | try: |
| 453 | manager.app.backend.ensure_chords_allowed() |
| 454 | except NotImplementedError as e: |
| 455 | raise pytest.skip(e.args[0]) |
| 456 | |
| 457 | c = chain( |
| 458 | chord(group(add.si(1, 0), add.si(1, 0), add.si(1, 0)), tsum.s()), |
| 459 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 460 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 461 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 462 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 463 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 464 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 465 | chord(group(add.s(1), add.s(1), add.s(1)), tsum.s()), |
| 466 | chord(group(add.s(0), add.s(0), add.s(0)), tsum.s()), |
| 467 | ) |
| 468 | res = c() |
| 469 | assert res.get(timeout=TIMEOUT) == 29520 |
| 470 | |
| 471 | @flaky |
| 472 | def test_chain_of_a_chord_and_a_group_with_two_tasks(self, manager): |