+ lHjtRt^RIHt^RIt^RIt^RIHt^RIHtH t H t H t H t H t ^RIHt^RIHt^RIHtHtRtR tR tR tR tR tRtRt] ]]]3,.] ],3,t]!RR44t RR/RRllt!RRlt"RRlt#RRRR/RRllt$RR/RRllt%RR/RR llt&R!R"lt'R#R$lt(R#)%a3The one lifecycle every ``manage_connections`` operation follows, whatever the target kind. ``run_operation`` mints the op, registers it in ``live``, lets the kind prepare its targets (a managed mint, an MCP catalog check), emits the card through the session callback, then loops: sleep on ``op.wake`` for at most one tick, run the kind's ``observe`` hook, settle when every target is resolved or the deadline passes. ``connection.respond`` reaches the loop by transitioning the op through ``live`` and setting ``wake``; ``/stop`` sets the thread interrupt flag.) annotationsN) dataclass)AnyCallableDictListOptionalSequence)live) SettleReason)ConnectionOperationTargetunknown_target mixed_kindslink_still_validsettled not_allowedrefusedg@g?cH]tRt^"t$RtR]R&R]R&R]R&RtR]R &R tR#) KindzPer-kind hooks. ``prepare`` runs once before the card; ``observe`` runs every tick and may transition targets; ``note`` is the model-facing guidance appended to the settled result.z%Callable[[ConnectionOperation], None]prepareobservestrnoteNz9Optional[Callable[[ConnectionOperation], dict[str, Any]]]result)__name__ __module__ __qualname____firstlineno____doc____annotations__r__static_attributes__r9/home/ubuntu/.hermes/hermes-agent/tools/connectors/run.pyrr"s&a32 22 IHLF ELr#r initiatorc(V^8dQhRRRRRRRR/#) operationr namesz Sequence[str]r% Optional[str]returnr)formats"r$ __annotate__r-.s+88*8=8P]8iv8r#c,aa^RIHpHoHoVUu.uFq@P V4NK pp\ ;QJdRV4F 'gK RM RM !RV44'd\ #\VUu0uFqfPkK up4^8wd\#VUu.uF7qfPSPSP39gK+VPNK9 pp\V4\V48wd\#VP'd\ #\ ;QJd VV3RlV4F 'gK RM RM!VV3RlV44'd\"#V^,PR8XdB^RIHpHp Hp T !RT;'gTVP,R7p V !WVRVP.R 7R #^R IHp ^R IHp V P9VP:4'd V P6MT pV!W4'd\<#R #uupiuupiuupi) )Actor TargetStateallowedc3("TFqRJxK R#5iNr).0targets& r$ reissue..2s 0fT>sTFc3x<"TF/pS!VPVPSP4RJxK1 R#5ir4)kindstate initiated)r5r6r1r2s& r$r7r8;s0 c[bQW76;; k.C.C D L[bs7: connector) CARD_RETRYmanaged_clientmint) creates_guestr%call) reinitiateactorN)catalog)retry)tools.connectors.contractr0r1r2r6anyUNKNOWN_TARGETlenr: MIXED_KINDSr;failedexpirednameLINK_STILL_VALIDrSETTLED NOT_ALLOWEDtools.connectors.managedr>r?r@rBusertools.connectorsrEtools.connectors.mcprFownsop_idREFUSED)r(r)r%r0rNtargetsr6staler>r?r@clientrErFrerunr1r2s&&$ @@r$reissuer].sEE278%$%%G8 s 0 0sss 0 000 g .gFKKg ./14'. lwV,,;CUCUWbWjWjBk2k[V[[wE l 5zS\! s c[b csss c[b cccqz+%MMdi>U>U:\e\j\jk V$ejjI(*$\\)//::GMMEI--7747-9 / lsH5H (H Hc$V^8dQhRRRRRR/#)r'r(r rawrr+Noner)r,s"r$r-r-Js'bb/bcbdbr#c^RIHpHpHp\ WP 4'dVP W4R#VPVP4'd VP M VP !W4R#)zHand the card's answer to the module running this operation (a catalog install or an MCP one); a managed operation's card only skips and continues, which the MCP fold also covers.)rEdisplaymcpN) rTrErbrc isinstanceDisplayOperation apply_answerrVrW)r(r_rErbrcs&& r$rfrfJsX76)5566Y,$\\)//::W@P@PPR[ar#c$V^8dQhRRRRRR/#)r'r(r r_rr+boolr)r,s"r$r-r-Us"*r#c\W4VP'g2VP'd VP\P4VP'd\ P !V4VP#)zThe card's answer: apply it, settle once every target is resolved, close a settled operation. Returns whether it settled; raises ``IllegalTransition`` for an answer the operation refuses.)rfr all_resolvedsettler r close)r(r_s&&r$respondrmUsY    !7!7!7223 9   r# tick_secondsrBc<V^8dQhRRRRRRRRR R R R R RRRRR/ #)r'rYz list[Target]r:r session_keyr tool_call_idr*connection_callbackOptional[Callback]rnOptional[float]with_urls_in_resultrhrBz Optional[Any]r+r)r,s"r$r-r-_sb      , "  r#c 8\\WW7R7VVVVR7#)zQBlock the tool thread until the operation settles; return the tool's JSON string.)rprqrBrrrnru)open_and_driver )rYr:rprqrrrnrurBs&&$$$$$$r$ run_operationry_s' G<c /!/  r#c 0V^8dQhRRRRRRRRR R R R /# r'r(r r:rrrrsrnrtrurhr+rr)r,s"r$r-r-tsD" ,  "    r#c\P!V4\TTTTTR7# \Pd1p^RIHpT!RTP P R24uRp?#Rp?ii;i)zTRegister ``operation`` as the session's open one and drive it; one open per session.) tool_errorz8a connection operation is already open in this session (zj); it settles when the user finishes with the card, on Continue, or at its deadline. Do not start another.Nrw)r openOperationAlreadyOpentools.registryr}existingrWdrive_operation)r(r:rrrnruexcr}s&&$$$ r$rxrxtsx  )  /!/    $ $ -Fs||GYGYFZ[k k   s(A-%A("A-(A-c 0V^8dQhRRRRRRRRR R R R /#r{r)r,s"r$r-r-sD33"3 3, 3 " 3  3 3r#cVPV4VP4Ve)VP'gV!VP44\ WV4\ P !V4VPe(\P!VPV4RR7#VPVR7pRVR&VPVR&\P!VRR7# \ P !T4i;i)NF) ensure_ascii) with_urlsrstatusr) rsettle_if_all_resolvedrrequest_payload_watchr rlrjsondumpsr)r(r:rrrnrupayloads&&$$$ r$rrs Y((*  *93D3D3D  9 9 ; <y - 9 {{zz$++i0uEE)<=G!GHiiGFO ::gE 22 9s6C$"C$$C<c(V^8dQhRRRRRRRR/#) r'r(r r:rrnrtr+r`r)r,s"r$r-r-s*++)++_+Y]+r#c^RIHpVf\MTpVP'gV!4'd"VP \ P 4R#\P!4VP8d"VP \ P4R#VPV4VP'gVP4'dR#\W4KR#)r/is_interruptedN) tools.interruptrWATCH_INTERVAL_SECONDSrrkr interrupttime deadline_atdeadlinerr_sleep_until_wake)r(r:rnrticks&&& r$rrs.%1%9 !|D      \33 4  99;)// /   \22 3  Y     @ @ B B )* r#c$V^8dQhRRRRRR/#)r'r(r rfloatr+r`r)r,s"r$r-r-s"  !4 E d r#c^RIHp\\P!4V,VP4pVP 'gdV!4'gWV\P!4, pV^8:dM2VP P\\V44'gKtVP P4R#)zUSleep up to one tick, leaving early on ``wake``, the deadline, or the interrupt flag.rN) rrminrrrwakewait_WAKE_SLICE_SECONDSclear)r(rruntil remainings&& r$rrs.  d"I$9$9 :E(8(8DIIK' >  >>  s#6 B C C  NNr#))r __future__rrr dataclassesrtypingrrrrrr rTr rGr tools.connectors.operationr r rIrKrOrPrQrXrrdictrCallbackrr]rfrmryrxrrrrr#r$rs[# !@@!2B! %   T#s(^$hsm3 4 MM M8`d88b%)* %) 63 %) 30+$ r#