MCPcopy
hub / github.com/celery/celery / link_chain

Method link_chain

t/integration/test_canvas.py:642–645  ·  view source on GitHub ↗
(sig)

Source from the content-addressed store, hash-verified

640 link_b_sig = redis_echo.si(link_b_msg, redis_key=link_b_key)
641
642 def link_chain(sig):
643 sig.link(link_b_sig)
644 sig.link_error(identity.s('link_ab'))
645 return sig
646
647 inner_chain = link_chain(chain(identity.s('a'), add.s('b')))
648 flat_chain = chain(inner_chain, add.s('c'))

Callers

nothing calls this directly

Calls 3

linkMethod · 0.45
link_errorMethod · 0.45
sMethod · 0.45

Tested by

no test coverage detected