@@ -285,7 +285,6 @@ def unbind_connecting_task() -> None:
285285 client_id = self ._client_id ,
286286 server_id = self ._server_id ,
287287 session_id = self .session_id ,
288- max_retry = self ._transport_options .connection_retry_options .max_retry ,
289288 rate_limiter = self ._rate_limiter ,
290289 uri_and_metadata_factory = self ._uri_and_metadata_factory ,
291290 get_next_sent_seq = get_next_sent_seq ,
@@ -901,7 +900,6 @@ async def _do_ensure_connected[HandshakeMetadata](
901900 client_id : str ,
902901 session_id : str ,
903902 server_id : str ,
904- max_retry : int ,
905903 rate_limiter : LeakyBucketRateLimit ,
906904 uri_and_metadata_factory : Callable [
907905 [], Awaitable [UriAndMetadata [HandshakeMetadata ]]
@@ -918,11 +916,11 @@ async def _do_ensure_connected[HandshakeMetadata](
918916 logger .info ("Attempting to establish new ws connection" )
919917
920918 last_error : Exception | None = None
921- i = 0
919+ attempt_count = 0
922920 while rate_limiter .has_budget (client_id ):
923- if i > 0 :
924- logger .info (f"Retrying build handshake number { i } times" )
925- i += 1
921+ if attempt_count > 0 :
922+ logger .info (f"Retrying build handshake number { attempt_count } times" )
923+ attempt_count += 1
926924
927925 rate_limiter .consume_budget (client_id )
928926 transition_connecting ()
@@ -1050,7 +1048,7 @@ async def websocket_closed_callback() -> None:
10501048 do_close ()
10511049 raise RiverException (
10521050 ERROR_HANDSHAKE ,
1053- f"Failed to create ws after retrying { max_retry } number of times" ,
1051+ f"Failed to create ws after retrying { attempt_count } number of times" ,
10541052 ) from last_error
10551053
10561054 return None
0 commit comments