[j5SSKJr SSKrSSKrSSKJrJrJr SSKJ r SSK r SSK r SSK r \"S5r \ "S5rS SjrS Sjrg) ) annotationsN)TypeVarCallable Awaitable) ParamSpecT_Retval T_ParamSpecc# [R"5S:Xa"[R"U/UQ70UD6IShvN $[RR [ R"U/UQ70UD65IShvN $NCN7f)Nasyncio)sniffiocurrent_async_libraryr to_threadanyiorun_sync functoolspartial)funcargskwargss W/home/mande/repo/quber/.venv/lib/python3.13/site-packages/landingai_ade/_utils/_sync.pyrrst$$&)3&&t=d=f===))$000 > s!7BA=>B8A?9B?Bc^SU4SjjnU$)a# Take a blocking function and create an async one that receives the same positional and keyword arguments. Usage: ```python def blocking_func(arg1, arg2, kwarg1=None): # blocking code return result result = asyncify(blocking_function)(arg1, arg2, kwarg1=value1) ``` ## Arguments `function`: a blocking regular callable (e.g. a function) ## Return An async function that takes the same positional and keyword arguments as the original one, that when called runs the same original function in a thread worker and returns the result. c>># [T/UQ70UD6IShvN $N7f)N)r)rrfunctions rwrapperasyncify..wrapper7s!x9$9&9999s )rT_ParamSpec.argsrT_ParamSpec.kwargsreturnr)rrs` rasyncifyr s6: N)rCallable[T_ParamSpec, T_Retval]rrrrrr)rr"rz*Callable[T_ParamSpec, Awaitable[T_Retval]]) __future__rr rtypingrrrtyping_extensionsrrr anyio.to_threadrr rr rr!rr's^"//'  :  &  )5EQc r!