ttun_server/redis.py


1
2
3
4
5
6
7
8
9
10
11
12
13

import os

from redis.asyncio import ConnectionPool, Redis


class RedisConnectionPool:
    _pool: ConnectionPool | None = None

    @classmethod
    def get_connection(cls) -> Redis:
        if cls._pool is None:
            cls._pool = ConnectionPool.from_url(os.environ.get("REDIS_URL"))
        return Redis(connection_pool=cls._pool)