File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -696,8 +696,6 @@ async def send_rpc[R, A](
696696 service_name ,
697697 procedure_name ,
698698 ) from e
699- except Exception as e :
700- raise RiverException (ERROR_CODE_STREAM_CLOSED , str (e )) from e
701699
702700 if "ok" not in result or not result ["ok" ]:
703701 try :
@@ -1050,11 +1048,11 @@ async def websocket_closed_callback() -> None:
10501048 "Handshake failed, conn closed while sending response" ,
10511049 ) from e
10521050
1053- startup_grace_deadline_ms = (
1051+ handshake_deadline_ms = (
10541052 await get_current_time () + transport_options .handshake_timeout_ms
10551053 )
10561054 while True :
1057- if await get_current_time () >= startup_grace_deadline_ms :
1055+ if await get_current_time () >= handshake_deadline_ms :
10581056 raise RiverException (
10591057 ERROR_HANDSHAKE ,
10601058 "Handshake response timeout, closing connection" ,
You can’t perform that action at this time.
0 commit comments