| 1668 | visitor.on_group_end(self, **headers) |
| 1669 | |
| 1670 | def link(self, sig): |
| 1671 | # Simply link to first task. Doing this is slightly misleading because |
| 1672 | # the callback may be executed before all children in the group are |
| 1673 | # completed and also if any children other than the first one fail. |
| 1674 | # |
| 1675 | # The callback signature is cloned and made immutable since it the |
| 1676 | # first task isn't actually capable of passing the return values of its |
| 1677 | # siblings to the callback task. |
| 1678 | sig = sig.clone().set(immutable=True) |
| 1679 | return self.tasks[0].link(sig) |
| 1680 | |
| 1681 | def link_error(self, sig): |
| 1682 | # Any child task might error so we need to ensure that they are all |