Skip to content

Commit c675a56

Browse files
authored
Add return type to close functions (#3496)
1 parent ceb12fe commit c675a56

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

redis/client.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -550,7 +550,7 @@ def __exit__(self, exc_type, exc_value, traceback):
550550
def __del__(self):
551551
self.close()
552552

553-
def close(self):
553+
def close(self) -> None:
554554
# In case a connection property does not yet exist
555555
# (due to a crash earlier in the Redis() constructor), return
556556
# immediately as there is nothing to clean-up.
@@ -1551,7 +1551,6 @@ def _disconnect_raise_reset(
15511551
conn.retry_on_error is None
15521552
or isinstance(error, tuple(conn.retry_on_error)) is False
15531553
):
1554-
15551554
self.reset()
15561555
raise error
15571556

redis/cluster.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1227,7 +1227,7 @@ def _execute_command(self, target_node, *args, **kwargs):
12271227

12281228
raise ClusterError("TTL exhausted.")
12291229

1230-
def close(self):
1230+
def close(self) -> None:
12311231
try:
12321232
with self._lock:
12331233
if self.nodes_manager:
@@ -1669,7 +1669,7 @@ def initialize(self):
16691669
# If initialize was called after a MovedError, clear it
16701670
self._moved_exception = None
16711671

1672-
def close(self):
1672+
def close(self) -> None:
16731673
self.default_node = None
16741674
for node in self.nodes_cache.values():
16751675
if node.redis_connection:

0 commit comments

Comments
 (0)