Skip to content

Commit

Permalink
fix: django conf should not be modified
Browse files Browse the repository at this point in the history
  • Loading branch information
shangkun.yu committed Dec 1, 2022
1 parent d663090 commit 4cfc2ea
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions channels_redis/core.py
Expand Up @@ -11,7 +11,7 @@

import msgpack
from redis import asyncio as aioredis

from copy import deepcopy
from channels.exceptions import ChannelFull
from channels.layers import BaseChannelLayer

Expand Down Expand Up @@ -132,13 +132,14 @@ def create_pool(self, index):
if "address" in host:
return aioredis.ConnectionPool.from_url(host["address"])
elif "master_name" in host:
sentinels = host.pop("sentinels")
master_name = host.pop("master_name")
sentinel_kwargs = host.pop("sentinel_kwargs", None)
host_kwargs = deepcopy(host)
sentinels = host_kwargs.pop("sentinels")
master_name = host_kwargs.pop("master_name")
sentinel_kwargs = host_kwargs.pop("sentinel_kwargs", None)
return aioredis.sentinel.SentinelConnectionPool(
master_name,
aioredis.sentinel.Sentinel(sentinels, sentinel_kwargs=sentinel_kwargs),
**host
**host_kwargs
)
else:
return aioredis.ConnectionPool(**host)
Expand Down

0 comments on commit 4cfc2ea

Please sign in to comment.