o RWj5@s|ddlmZddlZddlZddlmZmZmZddlm Z ddl Z ddl Z ddl Z edZ e dZdddZdddZdS)) annotationsN)TypeVarCallable Awaitable) ParamSpecT_Retval T_ParamSpecfuncCallable[T_ParamSpec, T_Retval]argsT_ParamSpec.argskwargsT_ParamSpec.kwargsreturncsRtdkrtj|g|Ri|IdHStjtj|g|Ri|IdHS)Nasyncio)sniffiocurrent_async_libraryr to_threadanyiorun_sync functoolspartial)r r r rb/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/openai/_utils/_sync.pyrs   rfunction*Callable[T_ParamSpec, Awaitable[T_Retval]]csd fdd }|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 r rrrcstg|Ri|IdHS)N)r)r r rrrwrapper7szasyncify..wrapperN)r r r rrrr)rrrrrasyncifysr)r r r r r rrr)rr rr) __future__rrrtypingrrrtyping_extensionsrrranyio.to_threadrrrrrrrrs