From 486087cdb349dbc07b479d2286a02bdca310ea38 Mon Sep 17 00:00:00 2001 From: Tom van der Lee Date: Wed, 20 Mar 2024 21:48:45 +0100 Subject: Added websocket support --- ttun_server/redis.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'ttun_server/redis.py') diff --git a/ttun_server/redis.py b/ttun_server/redis.py index 3065dec..18fbca2 100644 --- a/ttun_server/redis.py +++ b/ttun_server/redis.py @@ -1,6 +1,8 @@ +import asyncio import os +from asyncio import get_running_loop -from aioredis import ConnectionPool, Redis +from redis.asyncio import ConnectionPool, Redis class RedisConnectionPool: @@ -9,9 +11,6 @@ class RedisConnectionPool: def __init__(self): self.pool = ConnectionPool.from_url(os.environ.get('REDIS_URL')) - def __del__(self): - self.pool.disconnect() - @classmethod def get_connection(cls) -> Redis: if cls.instance is None: -- cgit v1.2.3