+ iHj >a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t H t H t ]P!]4tRtRt] ]] ],] ],.R3,t]P*!RRR7tR]R &R R lt]P2R R l4tRRltRRltR#)a Live progress from inside a running tool call (MCP ``notifications/progress``) onto the agent's ``tool_progress_callback`` as ``tool.progress`` events. The executor binds a relay for each dispatched call (``bound_tool_progress``); a tool reads it on its own thread with ``current_tool_progress()`` and may invoke the result from any thread (the MCP client fires it on the MCP event loop). Emission is throttled per call so a chatty server cannot flood the UI; the first update and the one reaching ``total`` always pass. ) annotationsN)CallableIteratorOptionalz tool.progressg?tool_progress_reporter)defaultz2contextvars.ContextVar[Optional[ProgressReporter]]_currentc$V^8dQhRRRRRR/#) tool_namestr tool_call_idreturnProgressReporter)formats">/home/ubuntu/.hermes/hermes-agent/agent/tool_progress_relay.py __annotate__rs"3c>Nc^aaaaa\P!4oR.oRRVVVVV3RlllpV#)c(V^8dQhRRRRRRRR/#) r progressfloattotalzOptional[float]message Optional[str]rNoner)rs"rr_reporter..__annotate__ s/ [ [ [ [ [ae [rc f<VRJ;'dV^8;'dW8p\P!4pS;_uu_4S^,'d-V'g%VS^,, \8d RRR4R#VS^&RRR4V'd-\\ \ W, R4R4^d,4MRpS!\ S T;'gRRS \V4VfRM \V4VR7R# +'giL;i \d\PRS RR7R#i;i)Nrg?)r rrpercentz$tool.progress callback failed for %sT)exc_info) time monotonic_MIN_INTERVAL_SroundminmaxTOOL_PROGRESS_EVENTr Exceptionloggerdebug) rrrdonenowr callbacklastlockr r s &&& rreport_reporter..report sD DDUQYDD83Dnn TAwwtd1g (GTDGHM%C 0#6D %D 6 D #D0/D0)NN) threadingLock)r.r r r1r/r0sfff @@r _reporterr5s) >> D 5D [ [ Mrc$V^8dQhRRRRRR/#)r r r r rzIterator[None]r)rs"rrr1s!Src#"\PV'd\YT;'gR4MR4pRx\PV4R# \PT4i;i5i)zUBind this call's relay for the block (no-op when the agent has no progress callback).N)rsetr5reset)r.r r tokens&&& rbound_tool_progressr<0sI LLx8 8J8JK]a bE uus &A, A,AA,A))A,cV^8dQhRR/#)r rzOptional[ProgressReporter]r)rs"rrr:s9rc*\P4#)zDThe running call's reporter, or None outside a dispatched tool call.)rgetrrrcurrent_tool_progressr@:s <<>rc(V^8dQhRRRRRRRR/#)r namerrkwargsdictrr)rs"rrr?s/\\ \ \t\X\\rc0R\VPR4;'gR4R\T;'gR4R\VPR4;'gR4RVPR4RVPR4R V'd \V4/#R /#) zThe ``tool.progress`` wire payload every viewer surface publishes (gateway event stream and the legacy TUI gateway): ``percent`` is 0-100 when the server sent a ``total``, else None.tool_idr r8rBrrrr rN)r r?r)rBrrCs&&&rtool_progress_payloadrG?s s6::n5;;rTs# //   8 $%UHUOXc]CTIJ?J?U?UVnx|?} <}(  \r