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

Method apply

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

Source from the content-addressed store, hash-verified

1629 return result
1630
1631 def apply(self, args=None, kwargs=None, **options):
1632 args = args if args else ()
1633 kwargs = kwargs if kwargs else {}
1634 app = self.app
1635 if not self.tasks:
1636 return self.freeze() # empty group returns GroupResult
1637 options, group_id, root_id = self._freeze_gid(options)
1638 tasks = self._prepared(self.tasks, [], group_id, root_id, app)
1639 return app.GroupResult(group_id, [
1640 sig.apply(args=args, kwargs=kwargs, **options) for sig, _, _ in tasks
1641 ])
1642
1643 def set_immutable(self, immutable):
1644 for task in self.tasks:

Calls 4

freezeMethod · 0.95
_freeze_gidMethod · 0.95
_preparedMethod · 0.95
GroupResultMethod · 0.80