kKj :dZddlZddlZddlmZmZddlmZmZm Z m Z ddl Z ddl m Ze dZdedefd Zded efd ed edefd Ze deededdeeezfdZe d ddeededdeefdZdddeededeeeeezzfdZy)zAsync utilities for FastMCP.N) AwaitableCallable)AnyLiteralTypeVaroverload)run_syncTfnreturnct|tjr'|j}t|tjr'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 n/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/utilities/async_utils.pyis_coroutine_functionrs@ R** + WW R** +  & &r **.argskwargscbKttj|g|i|d{S7w)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_threadpoolrs.( (9(9"(Nt(Nv(NO OO Os &/-/ awaitablesreturn_exceptionsTc KywNrrs rgatherr"%s ")rFc Kywrr r!s rr"r",s r#cBKdgt|zdtdttddffd }t j 4d{}t |D]\}}|j|||dddd{S7<7#1d{7swYSxYww)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 clK |d{|<y7#t$r}r||<nYd}~yd}~wwxYwwr) BaseException)r&r'eresultsrs rrun_atzgather..run_atEs< !GAJ    s,44 1 ,414)lenintrr anyiocreate_task_group enumerate start_soon)rrr,tgr&r'r+s` @rr"r"3s )-vJ'?G1$&&((Bz*EAr MM&!R (+)( N )(((( NsHABB B 'B 3 B>B?BB BB BB)__doc__rrcollections.abcrrtypingrrrrr/anyio.to_threadr rr boolrrlistr)r"r rrr:s&"/22 > CL +c +d +PcP#&P25PP "1"t}" !m " "  ),1u~ !W $1 !WtA %&&r