diff --git a/broadcaster/_backends/redis.py b/broadcaster/_backends/redis.py index 096a033..cb91897 100644 --- a/broadcaster/_backends/redis.py +++ b/broadcaster/_backends/redis.py @@ -10,10 +10,11 @@ def __init__(self, url: str): parsed_url = urlparse(url) self._host = parsed_url.hostname or "localhost" self._port = parsed_url.port or 6379 + self._password = parsed_url.password or None async def connect(self) -> None: - self._pub_conn = await asyncio_redis.Connection.create(self._host, self._port) - self._sub_conn = await asyncio_redis.Connection.create(self._host, self._port) + self._pub_conn = await asyncio_redis.Connection.create(self._host, self._port, password=self._password) + self._sub_conn = await asyncio_redis.Connection.create(self._host, self._port, password=self._password) self._subscriber = await self._sub_conn.start_subscribe() async def disconnect(self) -> None: