Fixed issue with the redis proxy queue not working due to enqueing on the wrong queuev2.2.1

1 files changed, 4 insertions, 10 deletions

diff --git a/ttun_server/redis.py b/ttun_server/redis.py
index 18fbca2..fb9ff81 100644
--- a/ttun_server/redis.py
+++ b/ttun_server/redis.py
@@ -1,19 +1,13 @@
-import asyncio
 import os
-from asyncio import get_running_loop
 
 from redis.asyncio import ConnectionPool, Redis
 
 
 class RedisConnectionPool:
-    instance: 'RedisConnectionPool' = None
-
-    def __init__(self):
-       self.pool = ConnectionPool.from_url(os.environ.get('REDIS_URL'))
+    _pool: ConnectionPool | None = None
 
     @classmethod
     def get_connection(cls) -> Redis:
-        if cls.instance is None:
-            cls.instance = RedisConnectionPool()
-
-        return Redis(connection_pool=cls.instance.pool)
+        if cls._pool is None:
+            cls._pool = ConnectionPool.from_url(os.environ.get('REDIS_URL'))
+        return Redis(connection_pool=cls._pool)
\ No newline at end of file