+ Q(iRt^RIt^RIHtHt^RIHtHtHtH t ^RI t ^RI H t ]!R4tRRlt] RR l4t] R R /R R ll4tR R/RRlltR#)zAsync utilities for FastMCP.N) AwaitableCallable)AnyLiteralTypeVaroverload)run_syncTcbV^8dQhR\R\3,R\R\R\/#)fn.argskwargsreturn)rr)formats"c/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/utilities/async_utils.py __annotate__r s;PPcP#&P25PPcd"\\P!V.VO5/VB4GRjxL #L5i)zCall a sync function in a threadpool to avoid blocking the event loop. Uses anyio.to_thread.run_sync which properly propagates contextvars, making this safe for functions that depend on context (like dependency injection). N)run_sync_in_threadpool functoolspartial)r r rs&*,rcall_sync_fn_in_threadpoolr s-( (9(9"(Nt(Nv(NO OO Os '0.0cV^8dQhR\\,R\R,R\\\,,/#)r awaitablesreturn_exceptionsTr)rr rlist BaseException)rs"rrrs8""1"t}" !m "rc"R#5iNrrs$*rgatherr"s "r.cvV^8dQhR\\,R\R,R\\,/#)r rrFr)rr rr)rs"rrr s21u~ !Wrc"R#5irr r!s$*rr"r"s r#Fc V^8dQhR\\,R\R\\,\\\,,,/#)r rrr)rr boolrr)rs"rrr&s=1 !WtA %&&rcFaa"R.\V4,oRVV3Rllp\P!4;_uu_4GRjxL p\V4FwrEVP W$V4K RRR4GRjxL S#L<L +GRjxL 'giS#;i5i)asRun awaitables concurrently and return results in order. Uses anyio TaskGroup for structured concurrency. Args: *awaitables: Awaitables to run concurrently return_exceptions: If True, exceptions are returned in results. If False, first exception cancels all and raises. Returns: List of results in the same order as input awaitables. NcJV^8dQhR\R\\,RR/#)r iawrN)intrr )rs"rrgather..__annotate__8s%1$rc~<"VGRjxL SV&R#L \dpS'd TST&Rp?R#hRp?ii;i5ir)r)r*r+eresultsrs&& rrun_atgather..run_at8s6 !GAJ     s0== : 5=5:=)lenanyiocreate_task_group enumerate start_soon)rrr1tgr*r+r0sd* @rr"r"&s{ )-vJ'?G&&(((Bz*EA MM&R (+)( N )((( NsM?B!BB!'B. B!9B:B!B!B B  B B  B!)__doc__rcollections.abcrrtypingrrrrr4anyio.to_threadrrr rr"r rrr=sk"/22 > CLP " "  (+  #r