MCPcopy
hub / github.com/celery/celery / redis_echo_group_id

Function redis_echo_group_id

t/integration/tasks.py:275–277  ·  view source on GitHub ↗
(self, _, redis_key="redis-group-ids")

Source from the content-addressed store, hash-verified

273
274@shared_task(bind=True)
275def redis_echo_group_id(self, _, redis_key="redis-group-ids"):
276 redis_connection = get_redis_connection()
277 redis_connection.rpush(redis_key, self.request.group)
278
279
280@shared_task

Callers

nothing calls this directly

Calls 2

get_redis_connectionFunction · 0.85
rpushMethod · 0.80

Tested by

no test coverage detected