File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -1085,6 +1085,11 @@ async def _do_ensure_connected[HandshakeMetadata](
10851085
10861086 last_error : Exception | None = None
10871087 attempt_count = 0
1088+
1089+ handshake_deadline_ms = (
1090+ get_current_time () + transport_options .handshake_timeout_ms / 1000
1091+ )
1092+
10881093 while rate_limiter .has_budget (client_id ):
10891094 if (state := get_state ()) in TerminalStates or state in ActiveStates :
10901095 logger .info (f"_do_ensure_connected stopping due to state={ state } " )
@@ -1143,10 +1148,6 @@ async def websocket_closed_callback() -> None:
11431148 "Handshake failed, conn closed while sending response" ,
11441149 ) from e
11451150
1146- handshake_deadline_ms = (
1147- get_current_time () + transport_options .handshake_timeout_ms
1148- )
1149-
11501151 if get_current_time () >= handshake_deadline_ms :
11511152 raise RiverException (
11521153 ERROR_HANDSHAKE ,
You can’t perform that action at this time.
0 commit comments