Skip to content

Commit 063e795

Browse files
committed
Make sure active connection will be disconnected on failover
1 parent 6556e8a commit 063e795

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

redis/multidb/event.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
from typing import List
22

33
from redis.client import Redis
4-
from sphinx.events import EventListener
54

65
from redis.event import EventListenerInterface, OnCommandsFailEvent
76
from redis.multidb.database import SyncDatabase
@@ -64,6 +63,7 @@ def listen(self, event: ActiveDatabaseChanged):
6463
event.old_database.client.close()
6564

6665
if isinstance(event.old_database.client, Redis):
66+
event.old_database.client.connection_pool.update_active_connections_for_reconnect()
6767
event.old_database.client.connection_pool.disconnect()
6868

6969
class RegisterCommandFailure(EventListenerInterface):

0 commit comments

Comments
 (0)