MCPcopy
hub / github.com/celery/celery / _apply_chord_incr

Method _apply_chord_incr

celery/backends/base.py:1129–1132  ·  view source on GitHub ↗
(self, header_result_args, body, **kwargs)

Source from the content-addressed store, hash-verified

1127 return meta
1128
1129 def _apply_chord_incr(self, header_result_args, body, **kwargs):
1130 self.ensure_chords_allowed()
1131 header_result = self.app.GroupResult(*header_result_args)
1132 header_result.save(backend=self)
1133
1134 def on_chord_part_return(self, request, state, result, **kwargs):
1135 if not self.implements_incr:

Callers

nothing calls this directly

Calls 3

saveMethod · 0.95
GroupResultMethod · 0.80
ensure_chords_allowedMethod · 0.45

Tested by

no test coverage detected