-2i5ddlmZddlZddlZddlmZmZmZddlm Z ddl Z ddl Z ddl Z edZ e dZddZddZdS)) annotationsN)TypeVarCallable Awaitable) ParamSpecT_Retval T_ParamSpecfuncCallable[T_ParamSpec, T_Retval]argsT_ParamSpec.argskwargsT_ParamSpec.kwargsreturncKtjdkrtj|g|Ri|d{VStjt j|g|Ri|d{VS)Nasyncio)sniffiocurrent_async_libraryr to_threadanyiorun_sync functoolspartial)r r rs R/var/www/html/pixcura-vrs/venv/lib/python3.11/site-packages/openai/_utils/_sync.pyrrs$&&)33&t=d===f=========))$000000      function*Callable[T_ParamSpec, Awaitable[T_Retval]]cdfd }|S) ac 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. r r rrrrc4Ktg|Ri|d{VS)N)r)r rrs rwrapperzasyncify..wrapper7s7x9$999&999999999r)r r rrrr)rr s` rasyncifyr"s(6:::::: Nr)r r r r rrrr)rr rr) __future__rrrtypingrrrtyping_extensionsrrranyio.to_threadrr rr"r!rrr's""""""//////////''''''  7:  i && r