Skip to content

Commit c0d24e6

Browse files
committed
Revert weakref changes
1 parent 28eee0c commit c0d24e6

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

redis/asyncio/sentinel.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import asyncio
22
import random
3+
import weakref
34
from typing import AsyncIterator, Iterable, Mapping, Optional, Sequence, Tuple, Type
45

56
from redis.asyncio.client import Redis
@@ -28,10 +29,8 @@ def __init__(self, **kwargs):
2829
super().__init__(**kwargs)
2930

3031
def __repr__(self):
31-
pool = self.connection_pool
3232
s = (
3333
f"<{self.__class__.__module__}.{self.__class__.__name__}"
34-
f"(service={pool.service_name}"
3534
)
3635
if self.host:
3736
host_info = f",host={self.host},port={self.port}"
@@ -116,7 +115,7 @@ def __init__(self, service_name, sentinel_manager, **kwargs):
116115
self.is_master = kwargs.pop("is_master", True)
117116
self.check_connection = kwargs.pop("check_connection", False)
118117
super().__init__(**kwargs)
119-
self.connection_kwargs["connection_pool"] = self
118+
self.connection_kwargs["connection_pool"] = weakref.proxy(self)
120119
self.service_name = service_name
121120
self.sentinel_manager = sentinel_manager
122121
self.master_address = None

0 commit comments

Comments
 (0)