MCPcopy
hub / github.com/celery/celery / get_key_for_chord

Method get_key_for_chord

celery/backends/base.py:995–999  ·  view source on GitHub ↗

Get the cache key for the chord waiting on group with given id.

(self, group_id, key='')

Source from the content-addressed store, hash-verified

993 return self._get_key_for(self.group_keyprefix, group_id, key)
994
995 def get_key_for_chord(self, group_id, key=''):
996 """Get the cache key for the chord waiting on group with given id."""
997 if not group_id:
998 raise ValueError(f'group_id must not be empty. Got {group_id} instead.')
999 return self._get_key_for(self.chord_keyprefix, group_id, key)
1000
1001 def _get_key_for(self, prefix, id, key=''):
1002 key_t = self.key_t

Callers 7

on_chord_part_returnMethod · 0.95
test_global_keyprefixMethod · 0.80
_apply_chord_incrMethod · 0.80
on_chord_part_returnMethod · 0.80
_apply_chord_incrMethod · 0.80
_apply_chord_incrMethod · 0.80

Calls 1

_get_key_forMethod · 0.95

Tested by 2

test_global_keyprefixMethod · 0.64