$j dZddlZddlZddlmZmZddlmZmZm Z m Z ddl Z ddl m Ze dZdedefd Zded efd ed edefd Ze deededdeeezfdZe d ddeededdeefdZdddeededeeeeezzfdZdS)zAsync utilities for FastMCP.N) AwaitableCallable)AnyLiteralTypeVaroverload)run_syncTfnreturnct|tjr!|j}t|tj!t j|S)aCheck if a callable is a coroutine function, unwrapping functools.partial. ``inspect.iscoroutinefunction`` returns ``False`` for ``functools.partial`` objects wrapping an async function on Python < 3.12. This helper unwraps any layers of ``partial`` before checking. ) isinstance functoolspartialfuncinspectiscoroutinefunction)r s e/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/fastmcp/utilities/async_utils.pyis_coroutine_functionrsH R* + + W R* + +  &r * **.argskwargscVKttj|g|Ri|d{VS)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_threadpoolrr)r rrs rcall_sync_fn_in_threadpoolrsC( (9"(Nt(N(N(Nv(N(NOO O O O O O OOr awaitablesreturn_exceptionsTc KdSNrrs rgatherr"%s "cr)rFc KdSrr r!s rr"r",s crcLKdgt|zdtdttddffd }t j4d{V}t |D]\}}|||| dddd{Vn#1d{VswxYwYS)aRun 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. Niawr cfK |d{V|<dS#t$r}r||<nYd}~dSd}~wwxYwr) BaseException)r%r&eresultsrs rrun_atzgather..run_atEsi !GAJJJ        s  0 +0)lenintrr anyiocreate_task_group enumerate start_soon)rrr+tgr%r&r*s` @rr"r"3sU )-vJ'?G1$&(()))))))Bz** ) )EAr MM&!R ( ( ( ( )))))))))))))))))))))))))))) Ns-B B B)__doc__rrcollections.abcrrtypingrrrrr.anyio.to_threadr rr boolrrlistr(r"r rrr9s""////////222222222222 >>>>>> GCLL +c +d + + + +PcP#&P25PPPPP "1"t}" !m """ "  ),1u~ !W $1 !WtA %&&r