ޠj\dSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r J r J r SSK J r JrJr SSKJr SSKJrJrJrJrJrJr SSKJr \R8"\5rSS KJ r! SS K"J#r#J$r$ SS K%J r& S r'S4S jr)\)"SS5r*\)"SS5r+\)"SS5r,\)"SS5r-\)"SS5r.S5Sjr/S6Sjr0Sr1Sr2Sr3S7Sjr4S8S9Sjjr5"SS5r6"S S!5r7\8"1S"k5r9S#r:S:S$jr;S;S%jr<SS(S).S>S*jjr?S(SSSS+SSS,S S-S S\*S.. S?S/jjr@SSSS0.S@S1jjrAS(SSSS+SSS,S S-S S\*S.. SAS2jjrBSSSS0.SBS3jjrCg!\(a S=r!r&S=r#r$S r'GNIf=f)Cz> / //r1cUc[$[U[R"5- S5n[cU$[ [U5$)zDPer-attempt open timeout, clamped so it cannot outlive ``deadline``.g)WS_OPEN_TIMEOUTmaxr.r/min)deadline remainings r!open_timeout_forr9Hs?Ht~~//5I  **r1zWebSocket-based execution requires the 'websockets' package, which ships with langsmith by default. Reinstall with: pip install --upgrade langsmithcX[(d[[5e[[[ 4$)zCReturn the cached sync websockets symbols, or raise if unavailable.)WEBSOCKETS_AVAILABLE ImportError_MISSING_WEBSOCKETS_MSG_ws_connect_syncrrr0r1r!_ensure_websocketsr?Xs#  122 -/? ??r1cX[(d[[5e[[[ 4$)zDReturn the cached async websockets symbols, or raise if unavailable.)r;r<r=_ws_connect_asyncrrr0r1r!_ensure_websockets_asyncrB_s#  122 .0@ @@r1cPURSS5RSS5nUS3$)z;C=B>>Cc# UR(aMUR(d;URR[R"SUS.55IShvN gggN7f)Nrvrwryrzs r!r{ _AsyncWSStreamControl.send_inputs@ 88DLL((-- GT+J KL L L)8 LsAA$A"A$r}Nr~rrrrr0r1r!rrs3/  Mr1r>i@c[[USS5SS5n[U[5(aUS[R SSS9nO [U[ 5(a US[nOg[ R"U5n[U[5(aURS5OSn[U[5(dgURS5nURS 5n[U[ 5(a U(aU/O/n[U[ 5(aU(aURS U35 U(a'S RU5[U5S :aS -$S-$S$![[4a gf=f)z=Return bounded, user-facing detail from a rejected handshake.responseNbodyzutf-8rD)errorsdetailmessageerror_idz error_id=z ())getattr isinstancebytes_MAX_HANDSHAKE_ERROR_BYTESdecoderrnloads TypeErrorrdictgetappendjoinlen)excrpayloadrrrpartss r!_handshake_server_detailrs> 73 D164 @D$//077 7R D#  //0**T"'1$&?&?W[[ "TF fd # #jj#Gzz*%H#GS11gWI2E(C  X y +,AF499U SZ!^r =P =PDP z "s'EE10E1c[[USS5SS5nUcgURS5n[U5n[ R"U5(aUS:aU$S$![[[ 4a gf=f)zBReturn a non-negative Retry-After delay from a rejected handshake.rNrJz Retry-Afterr)rrrAttributeErrorrrmathisfinite)rrJrdelays r!_handshake_retry_afterrsygc:t4iFGkk-(c MM%((UaZ5ATA Iz 2sAA76A7chURb UR$[R"US-U5$)z9Prefer a server hint, otherwise jitter the local backoff.g?) retry_afterrandomuniform)rexponential_backoffs r! _retry_delayrs0 " >>-35H IIr1c,[[USS5SS5n[U5nU(aSU3OSU3nUS:Xa[SUS35UeU[;a[ SUS U3[ U5S 9UeUb[S US U35Ue[S USU35Ue)uRaise a clear error when the WebSocket upgrade handshake fails. Covers both a rejection carrying an HTTP status (``InvalidStatus`` — most commonly 404 when the server lacks the /execute/ws endpoint) and a response that isn't valid HTTP at all (``InvalidMessage``, "did not receive a valid HTTP response") — e.g. a stopped or recycled sandbox dataplane answering the upgrade with garbage. Both subclass ``InvalidHandshake``. rN status_codez: izJThe sandbox server does not support WebSocket command execution (endpoint z returned 404). Ensure the server is updated to a version that supports the /execute/ws endpoint, or use run() without wait=False or callbacks.z7WebSocket upgrade temporarily rejected by server (HTTP r)rz+WebSocket upgrade rejected by server (HTTP z): zWebSocket upgrade to zM failed (no valid HTTP response); the sandbox may be stopped or unreachable: )rrr _TRANSIENT_HANDSHAKE_STATUSESrr)rrFstatus server_detailsuffixs r!_raise_for_invalid_handshaker sWS*d3]D IF,S1M%2r- !"SE F }$!5 6    ..-EfXQvh W.s3  $9&SE J   ! x(669U <  r1r command_idc>URSS5nURSS5nUS:Xa [U5eUS:Xa#[U(aSU3OUU(aSUS 9eS US 9eUS :Xa#[U(aS U3OUU(aSUS 9eS US 9e[UU(aSUS 9eS US 9e) z!  %%#0: | , %/k!  5>!  !++ 1: r1z /bin/bashi,iX) rtimeoutenvcwdshell on_stdout on_stderr idle_timeoutkill_on_disconnect ttl_secondsptyrJ open_timeoutc ^^^^^^^^ ^ ^ ^ ^ ^^^^^^^[5ummm[U5m[X5m[5mSUUUUUUUU U U UUU UUUU UU4SjjnU"5T4$)a(Execute a command over WebSocket, yielding raw message dicts. Returns a tuple of (message_iterator, control). The control object provides send_kill() and send_input() methods for the CommandHandle. The iterator yields dicts with a "type" field: - {"type": "started", "command_id": "...", "pid": N} - {"type": "stdout", "data": "...", "offset": N} - {"type": "stderr", "data": "...", "offset": N} - {"type": "exit", "exit_code": N} If on_stdout/on_stderr callbacks are provided, they are invoked as data arrives in addition to yielding the messages. c 3># T"TTT[[[S9nT RU5 STTTT TTS.nT (aT US'T (aT US'T (aT US'T(aSUS'UR [ R "U55 UHn[ R"U5nURS 5nUS :XaUv M6US :XaT(a T"US 5 Uv MTUS :XaT(a T"US 5 Uv MrUS:XaUv SSS5 T R5 gUS:XdM[U5 M SSS5 T R5 g!,(df  N=f!Tan[UT5 SnAN9SnAfTaKnUR(a&URRS:Xa [S5Ue[SU35UeSnAf[ ["4an[%SU35UeSnAff=f!T R5 f=f7fNadditional_headersrrq ping_interval ping_timeoutexecute)rjrtimeout_secondsridle_timeout_secondsrrrrrTrrjstartedstdoutrxstderrexitr(Server is reloading, reconnect to resume*WebSocket connection closed unexpectedly: Failed to connect to sandbox: WS_CLOSE_TIMEOUTWS_PING_INTERVALWS_PING_TIMEOUTr_rmrnrorrrcrrrcvdcoderr OSError RuntimeErrorr )r^rraw_msgrmsg_typeerrrrcontrolrrrrrrrrrequest_headersrrr ws_connectrFs r!_streamrun_ws_stream.._streamtsG #2)..,  b!&&'.",8*<#.+,6GL)%(GEN%(GEN%)GEN 7+, "G**W-C"wwvH9,! !X-$%c&k2! !X-$%c&k2! !V+! eL OO %"W,-c2- "?L OO Mn  4 (F 3 3 vv!&&++-.>)> # T "T T [[[[S9nTR U5 UR [ R"STT T S.55 UHln[ R"U5nURS5nUS;aUv M6US:XaUv SSS5 TR5 gUS:XdMb[UTS9 Mn SSS5 TR5 g!,(df  N=f!Tan[UT 5 SnAN9SnAfTaKnUR(a&URRS :Xa [S 5Ue[!S U35UeSnAf["[$4an['S U35UeSnAff=f!TR5 f=f7f Nrr)rjrrrrj)rrrrrrrrrrr4rrrr_rmrnrorrrcrrrrrr rrr )r^rrrrrrrrrrrr rFs r!r $reconnect_ws_stream.._streams5 #2,..,  b!JJ$/*4-:-:   "G**W-C"wwvH#BB! !V+! Ah OO %"W,-cjI "/h OO iJ  4 (F 3 3 vv!&&++-.>) D F FAEF1FFFFFr r ) rErIrrrrJr rrrrr rFs ``` @@@@@@r!reconnect_ws_streamrsN.6H5I2J "2 = )F)';O G66p 9g r1c ^^^^^^^^ ^ ^ ^ ^ ^^^^^^^# [5ummm[U5m[X5m[5mSUUUUUUUU U U UUU UUUU UU4SjjnU"5T4$7f)zUAsync equivalent of run_ws_stream. Returns (async_message_iterator, async_control). c ># T"TTT[[[S9IShvN nT RU5 STTTT TTS.nT (aT US'T (aT US'T (aT US'T(aSUS'UR [ R "U55IShvN UShvN n[ R"U5nURS 5nUS :XaU7v M=US :XaT(a T"US 5 U7v M\US :XaT(a T"US 5 U7v M{US:Xa'U7v SSS5IShvN T R5 gUS:XdM[U5 MGN<NNN1 SSS5IShvN O!,IShvN (df  O=f!Tan[UT5 SnAOySnAfTaKnUR(a&URRS:Xa [S5Ue[SU35UeSnAf[ ["4an[%SU35UeSnAff=fT R5 g!T R5 f=f7frr)r^rrrrrrrrrrrrrrrrrrrrrrws_connect_asyncrFs r!r $run_ws_stream_async.._stream9s2A '#2)..,  b!&&'.",8*<#.+,6GL)%(GEN%(GEN%)GENggdjj1222%'3'**W-C"wwvH9,! !X-$%c&k2! !X-$%c&k2! !V+! [@ OO %"W,-c2_633;:&(;b  4 (F 3 3 vv!&&++-.>)F ? F FH3FH F)$H3) H2AG88H HHH3"I3IIrzAsyncIterator[dict]rBrGrLr)rErIrrrrrrrrrrrrrJrr rrrrrrFs ```````````` ` @@@@@@r!run_ws_stream_asyncrsa. # T "T T [[[[S9IShvN nTR U5 UR [ R"STT T S.55IShvN UShvN n[ R"U5nURS5nUS;aU7v M=US:Xa'U7v SSS5IShvN TR5 gUS:XdMr[UTS9 M~NNN}N/ SSS5IShvN O!,IShvN (df  O=f!Tan[UT 5 SnAOySnAfTaKnUR(a&URRS :Xa [S 5Ue[!S U35UeSnAf["[$4an['S U35UeSnAff=fTR5 g!TR5 f=f7frr)r^rrrrrrrrrrrrrFs r!r *reconnect_ws_stream_async.._streams1 '#2,..,  b!ggJJ$/*4-:-:    &( J'**W-C"wwvH#BB! !V+! ;` OO %"W,-cjI?  J+*&(+B  4 (F 3 3 vv!&&++-.>)r;r<r"r4rrrr-r2r9r=r?rBrGrLrNr frozensetrrrrrrrrrrr!r0r1r!r6sB"  <<**'5   8 $ !FHB (8"= BBG8"= :B?!!DcJ0+Q @A"DH0 0%@000G0Gf"M"MT!**C D&Q4 BJ (J?DJ J!H;=J$(0404$+/$3#pp pp  p  p "p p p.p.pppp p )!p""#p$-%pp+/TT TT  T  T)T-TB$(0404$+/$3#`` ``  `  ` "` ` `.`.```` ` )!`""#`$7%`P+/CC CC  C  C)C7C{!+//(*..' !s F,,G?G