MCPcopy
hub / github.com/celery/celery / freeze

Method freeze

celery/canvas.py:1093–1102  ·  view source on GitHub ↗
(self, _id=None, group_id=None, chord=None,
               root_id=None, parent_id=None, group_index=None)

Source from the content-addressed store, hash-verified

1091 # in order for a chain to be frozen, each of the members of the chain individually needs to be frozen
1092 # TODO figure out why we are always cloning before freeze
1093 def freeze(self, _id=None, group_id=None, chord=None,
1094 root_id=None, parent_id=None, group_index=None):
1095 # pylint: disable=redefined-outer-name
1096 # XXX chord is also a class in outer scope.
1097 _, results = self._frozen = self.prepare_steps(
1098 self.args, self.kwargs, self.tasks, root_id, parent_id, None,
1099 self.app, _id, group_id, chord, clone=False,
1100 group_index=group_index,
1101 )
1102 return results[0]
1103
1104 def stamp(self, visitor=None, append_stamps=False, **headers):
1105 visitor_headers = None

Callers

nothing calls this directly

Calls 1

prepare_stepsMethod · 0.95

Tested by

no test coverage detected