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

Method apply

celery/canvas.py:1280–1288  ·  view source on GitHub ↗
(self, args=None, kwargs=None, **options)

Source from the content-addressed store, hash-verified

1278 return tasks, results
1279
1280 def apply(self, args=None, kwargs=None, **options):
1281 args = args if args else ()
1282 kwargs = kwargs if kwargs else {}
1283 last, (fargs, fkwargs) = None, (args, kwargs)
1284 for task in self.tasks:
1285 res = task.clone(fargs, fkwargs).apply(
1286 last and (last.get(),), **dict(self.options, **options))
1287 res.parent, last, (fargs, fkwargs) = last, res, (None, None)
1288 return last
1289
1290 @property
1291 def app(self):

Callers 1

apply_asyncMethod · 0.95

Calls 3

applyMethod · 0.45
cloneMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected