diff --git a/services/redis.py b/services/redis.py
index 0f244c5..e10f15b 100644
--- a/services/redis.py
+++ b/services/redis.py
@@ -9,16 +9,17 @@ class RedisCache:
         self.pubsub_channels = []
         self._redis = None
         self._pubsub = None
+        self.loop = asyncio.get_event_loop()
 
     async def connect(self):
-        self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True)
-        await self._redis.connection_pool.connect()
+        self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True, loop=self.loop)
+        await self._redis.connection_pool.get_connection()
         self._pubsub = self._redis.pubsub()
         response = await self.execute('PING')
         print(f"[redis] PING response: {response}")
 
     async def disconnect(self):
-        self._redis.connection_pool.disconnect()
+        self._redis.connection_pool.re
         self._redis = None
         self._pubsub = None