MCPcopy
hub / github.com/celery/celery / clone

Method clone

celery/canvas.py:1005–1012  ·  view source on GitHub ↗
(self, *args, **kwargs)

Source from the content-addressed store, hash-verified

1003 return NotImplemented
1004
1005 def clone(self, *args, **kwargs):
1006 to_signature = maybe_signature
1007 signature = super().clone(*args, **kwargs)
1008 signature.kwargs['tasks'] = [
1009 to_signature(sig, app=self._app, clone=True)
1010 for sig in signature.kwargs['tasks']
1011 ]
1012 return signature
1013
1014 def unchain_tasks(self):
1015 """Return a list of tasks in the chain.

Callers 15

__or__Method · 0.95
unchain_tasksMethod · 0.45
prepare_stepsMethod · 0.45
applyMethod · 0.45
__init__Method · 0.45
linkMethod · 0.45
link_errorMethod · 0.45
_preparedMethod · 0.45
_unroll_tasksMethod · 0.45
_freeze_unrollMethod · 0.45
apply_asyncMethod · 0.45
applyMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected