Skip to content
This repository was archived by the owner on Aug 19, 2025. It is now read-only.

Commit e1f2977

Browse files
Kludexk1dav
andauthored
Add password support for Redis backend (#79)
Co-authored-by: k1dave6412 <14539608+k1dave6412@users.noreply.github.com>
1 parent f11d94d commit e1f2977

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

broadcaster/_backends/redis.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,10 +12,12 @@ def __init__(self, url: str):
1212
parsed_url = urlparse(url)
1313
self._host = parsed_url.hostname or "localhost"
1414
self._port = parsed_url.port or 6379
15+
self._password = parsed_url.password or None
1516

1617
async def connect(self) -> None:
17-
self._pub_conn = await asyncio_redis.Connection.create(self._host, self._port)
18-
self._sub_conn = await asyncio_redis.Connection.create(self._host, self._port)
18+
kwargs = {"host": self._host, "port": self._port, "password": self._password}
19+
self._pub_conn = await asyncio_redis.Connection.create(**kwargs)
20+
self._sub_conn = await asyncio_redis.Connection.create(**kwargs)
1921
self._subscriber = await self._sub_conn.start_subscribe()
2022

2123
async def disconnect(self) -> None:

0 commit comments

Comments
 (0)