import redis.asyncio as redis
import os

r = None

async def init_redis():
    global r
    r = redis.Redis.from_url(
        os.getenv("REDIS_URL", "redis://localhost"), decode_responses=True
    )