+:jbddlmZddlmZmZddlmZddlmZddl m Z edZ dd d  dd Z dd d  dd Z dd ZddZy )) annotations)CallableTypeVar)warn) get_asynclib)CapacityLimiterT_RetvalFN cancellablelimiterc\Ktj|g|||dd{S7w)a Call the given function with the given arguments in a worker thread. If the ``cancellable`` option is enabled and the task waiting for its completion is cancelled, the thread will still run its course but its return value (or any raised exception) will be ignored. :param func: a callable :param args: positional arguments for the callable :param cancellable: ``True`` to allow cancellation of the operation :param limiter: capacity limiter to use to limit the total amount of threads running (if omitted, the default limiter is used) :return: an awaitable that yields the return value of the function. r N)rrun_sync_in_worker_threadfuncr r argss Q/var/www/html/tokenscope/api/venv/lib/python3.12/site-packages/anyio/to_thread.pyrun_syncr s>*:99 !,g  s #,*,c^Ktdtt|g|||dd{S7w)NzWrun_sync_in_worker_thread() has been deprecated, use anyio.to_thread.run_sync() insteadr )rDeprecationWarningrrs rrr&s5  a$PP;P PP Ps $-+-c2tjS)z Return the capacity limiter that is used by default to limit the number of concurrent threads. :return: a capacity limiter object )rcurrent_default_thread_limiterrrr3s > 8 8 ::rc6tdttS)Nzycurrent_default_worker_thread_limiter() has been deprecated, use anyio.to_thread.current_default_thread_limiter() instead)rrrrrr%current_default_worker_thread_limiterr=s G * ++r) rzCallable[..., T_Retval]robjectr boolr zCapacityLimiter | Nonereturnr )rr ) __future__rtypingrrwarningsr_core._eventlooprabcr r rrrrrrrr%s"$* :  &*  ! $   :&* Q ! Q  Q Q$ Q  Q;,r