i "dZddlZddlmZmZddlmZmZmZm Z ddl Z ddl m Z edZdedefd ed ed efd Ze d eededd eeezfdZe ddd eededd eefdZddd eeded eeeeezzfdZy)zAsync utilities for FastMCP.N) AwaitableCallable)AnyLiteralTypeVaroverload)run_syncTfn.argskwargsreturncbKttj|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_threadpool functoolspartial)r r r s m/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/utilities/async_utils.pycall_sync_fn_in_threadpoolr s.( (9(9"(Nt(Nv(NO OO Os &/-/ awaitablesreturn_exceptionsTc KywNrrs rgatherrs ")rFc Kywrrrs rrrs rcBKdgt|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. NiawrclK |d{|<y7#t$r}r||<nYd}~yd}~wwxYwwr) BaseException)rr eresultsrs rrun_atzgather..run_at8s< !GAJ    s,44 1 ,414)lenintrr anyiocreate_task_group enumerate start_soon)rrr%tgrr r$s` @rrr&s )-vJ'?G1$&&((Bz*EAr MM&!R (+)( N )(((( NsHABB B 'B 3 B>B?BB BB BB)__doc__rcollections.abcrrtypingrrrrr(anyio.to_threadr rr rlistr"rboolrrr4s"/22 > CLPcP#&P25PP "1"t}" !m " "  ),1u~ !W $1 !WtA %&&r3