Function redis_echo_group_id

t/integration/tasks.py:275–277

(self, _, redis_key="redis-group-ids")

@shared_task(bind=True)
def redis_echo_group_id(self, _, redis_key="redis-group-ids"):
    redis_connection = get_redis_connection()
    redis_connection.rpush(redis_key, self.request.group)


@shared_task