a _ŠÝg. ã@sÆddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z ddl Z ddlZddlZ edƒZe dƒZejdkrŠejZndd d d d œd d„Zdd d dd œdd„Zdddœdd„ZdS)é)Ú annotationsN)ÚAnyÚTypeVarÚCallableÚ Awaitable)Ú ParamSpecÚT_RetvalÚ T_ParamSpec)éé zCallable[T_ParamSpec, T_Retval]úT_ParamSpec.argsúT_ParamSpec.kwargsr)ÚfuncÚargsÚkwargsÚreturncÏs@tj ¡}t ¡}tj|j|g|¢Ri|¤Ž}| d|¡IdHS)aŸAsynchronously 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) ÚasyncioÚeventsÚget_running_loopÚ contextvarsÚ copy_contextÚ functoolsÚpartialÚrunÚrun_in_executor)rrrÚloopÚctxÚ func_call©rúa/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/openai/_utils/_sync.pyÚ_asyncio_to_threads r cÏsNt ¡dkr(t|g|¢Ri|¤ŽIdHStj tj|g|¢Ri|¤Ž¡IdHS)Nr)ÚsniffioZcurrent_async_libraryr ÚanyioÚ to_threadZrun_syncrr)rrrrrrr#)s  ÿr#z*Callable[T_ParamSpec, Awaitable[T_Retval]])Úfunctionrcsddddœ‡fdd„ }|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. r r r)rrrcŸstˆg|¢Ri|¤ŽIdHS)N)r#)rr©r$rrÚwrapperSszasyncify..wrapperr)r$r&rr%rÚasyncify5sr')Ú __future__rÚsysrrrÚtypingrrrrZtyping_extensionsrr"r!Zanyio.to_threadrr Ú version_infor#r r'rrrrÚs