Test that a mid-point group in a chain completes.
(self, manager)
| 544 | assert res.get(timeout=TIMEOUT / 10) == [42, 42] |
| 545 | |
| 546 | def test_nested_chain_group_mid(self, manager): |
| 547 | """ |
| 548 | Test that a mid-point group in a chain completes. |
| 549 | """ |
| 550 | try: |
| 551 | manager.app.backend.ensure_chords_allowed() |
| 552 | except NotImplementedError as e: |
| 553 | raise pytest.skip(e.args[0]) |
| 554 | |
| 555 | sig = chain( |
| 556 | identity.s(42), # 42 |
| 557 | group(identity.s(), identity.s()), # [42, 42] |
| 558 | identity.s(), # [42, 42] |
| 559 | ) |
| 560 | res = sig.delay() |
| 561 | assert res.get(timeout=TIMEOUT) == [42, 42] |
| 562 | |
| 563 | def test_nested_chain_group_last(self, manager): |
| 564 | """ |