Function redis_echo

t/integration/tasks.py:268–271

Task that appends the message to a redis list.

(message, redis_key="redis-echo")

@shared_task
def redis_echo(message, redis_key="redis-echo"):
    """Task that appends the message to a redis list."""
    redis_connection = get_redis_connection()
    redis_connection.rpush(redis_key, message)


@shared_task(bind=True)