File tree Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -253,7 +253,6 @@ async def get_connection(
253
253
should go to the same replica.
254
254
"""
255
255
# If not an iter command or in master mode, call superclass' implementation
256
- breakpoint ()
257
256
if not (iter_req_id := options .get ("iter_req_id" , None )) or self .is_master :
258
257
return await super ().get_connection (command_name , * keys , ** options )
259
258
@@ -293,9 +292,7 @@ async def get_connection(
293
292
# This will connect to the host and port of the replica
294
293
else :
295
294
await connection .connect_to_address ((server_host , server_port ))
296
- breakpoint ()
297
295
await self .ensure_connection_connected_to_address (connection )
298
- breakpoint ()
299
296
except BaseException :
300
297
# Release the connection back to the pool so that we don't
301
298
# leak it
Original file line number Diff line number Diff line change @@ -54,7 +54,6 @@ def _connect_retry(self, same_address: bool = False):
54
54
if self .connection_pool .is_master :
55
55
self .connect_to (self .connection_pool .get_master_address ())
56
56
else :
57
- breakpoint ()
58
57
for slave in self .connection_pool .rotate_slaves ():
59
58
try :
60
59
return self .connect_to (slave )
You can’t perform that action at this time.
0 commit comments