MCPcopy
hub / github.com/celery/celery / apply

Method apply

celery/canvas.py:2158–2167  ·  view source on GitHub ↗
(self, args=None, kwargs=None,
              propagate=True, body=None, **options)

Source from the content-addressed store, hash-verified

2156 return self.run(tasks, body, args, task_id=task_id, kwargs=kwargs, **merged_options)
2157
2158 def apply(self, args=None, kwargs=None,
2159 propagate=True, body=None, **options):
2160 args = args if args else ()
2161 kwargs = kwargs if kwargs else {}
2162 body = self.body if body is None else body
2163 tasks = (self.tasks.clone() if isinstance(self.tasks, group)
2164 else group(self.tasks, app=self.app))
2165 return body.apply(
2166 args=(tasks.apply(args, kwargs).get(propagate=propagate),),
2167 )
2168
2169 @classmethod
2170 def _descend(cls, sig_obj):

Callers 1

apply_asyncMethod · 0.95

Calls 4

groupClass · 0.70
cloneMethod · 0.45
applyMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected