MCPcopy
hub / github.com/celery/celery / link

Method link

celery/canvas.py:1670–1679  ·  view source on GitHub ↗
(self, sig)

Source from the content-addressed store, hash-verified

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

Calls 2

setMethod · 0.45
cloneMethod · 0.45