Remove some unnecessary code

Author: ipmb

channels_redis/pubsub.py

@@ -427,26 +427,20 @@ def _notify_consumers(self, mtype):
     async def _ensure_redis(self):
         if self._redis is None:
             if self.master_name is None:
-                self._redis = aioredis.Redis(
-                    connection_pool=aioredis.ConnectionPool.from_url(
-                        self.host["address"]
-                    )
-                )
+                pool = aioredis.ConnectionPool.from_url(self.host["address"])
             else:
                 # aioredis default timeout is way too low
-                self._redis = aioredis.sentinel.Sentinel(
-                    self.host["sentinels"], socket_timeout=2
+                pool = aioredis.sentinel.SentinelConnectionPool(
+                    self.master_name,
+                    aioredis.sentinel.Sentinel(
+                        self.host["sentinels"], socket_timeout=2
+                    ),
                 )
-
-    def _get_aioredis_pool(self):
-        if self.master_name is None:
-            return self._redis.connection_pool
-        else:
-            return self._redis.master_for(self.master_name).connection_pool
+            self._redis = aioredis.Redis(connection_pool=pool)
 
     async def _get_redis_conn(self):
         await self._ensure_redis()
-        return aioredis.Redis(connection_pool=self._get_aioredis_pool())
+        return self._redis
 
     async def _put_redis_conn(self, conn):
         if conn: