g. ddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z ddl Z ddlZddlZ edZe dZejdkrejZnddZddZddZdS)) annotationsN)AnyTypeVarCallable Awaitable) ParamSpecT_Retval T_ParamSpec) funcCallable[T_ParamSpec, T_Retval]argsT_ParamSpec.argskwargsT_ParamSpec.kwargsreturnrcKtj}tj}t j|j|g|Ri|}|d|d{VS)aAsynchronously run function *func* in a separate thread. Any *args and **kwargs supplied for this function are directly passed to *func*. Also, the current :class:`contextvars.Context` is propagated, allowing context variables from the main thread to be accessed in the separate thread. Returns a coroutine that can be awaited to get the eventual result of *func*. N) asyncioeventsget_running_loop contextvars copy_context functoolspartialrunrun_in_executor)r rrloopctx func_calls Q/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/openai/_utils/_sync.py_asyncio_to_threadr"su~..00&((%cgtEdEEEfEE ))$ :::::::::cKtjdkrt|g|Ri|d{VStjt j|g|Ri|d{VS)Nr)sniffiocurrent_async_libraryr"anyio to_threadrun_syncrr)r rrs r!r(r()s$&&)33'>t>>>v>>>>>>>>>))$000000      r#function*Callable[T_ParamSpec, Awaitable[T_Retval]]cdfd }|S) aP Take a blocking function and create an async one that receives the same positional and keyword arguments. For python version 3.9 and above, it uses asyncio.to_thread to run the function in a separate thread. For python version 3.8, it uses locally defined copy of the asyncio.to_thread function which was introduced in python 3.9. 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. rrrrrr c4Ktg|Ri|d{VS)N)r()rrr*s r!wrapperzasyncify..wrapperSs7x9$999&999999999r#)rrrrrr )r*r.s` r!asyncifyr05s(<:::::: Nr#)r rrrrrrr)r rrrrrrr )r*rrr+) __future__rsysrrrtypingrrrrtyping_extensionsrr'r%anyio.to_threadr r version_infor(r"r0r/r#r!r7s"""""" 444444444444''''''  7:  i && v *;;;;$!!!!!!r#