,hFD"ddlmZddlZddlmZmZmZddlmZddl m Z m Z m Z ddl mZmZddlmZddlmZmZmZdd lmZdd lmZmZmZmZmZd d lmZd d l m!Z!m"Z"m#Z#d dl$m%Z%d dl&m'Z'm(Z(d dl)m*Z*d dl+m,Z,ejZdk\r ddlm.Z.m/Z/nddl0m.Z.m/Z/edZ1eddZ2e.dZ3 d%dZ4 d&dZ5Gddee2e Z6Gdde,Z7Gdd Z8eGd!d"Z9e d' d(d#Z:d)d$Z;y)*) annotationsN) AwaitableCallable Generator)Future)AbstractAsyncContextManagerAbstractContextManagercontextmanager) dataclassfield) isawaitable)LockThread get_ident) TracebackType)AnyGenericTypeVarcastoverload) _eventloop)get_async_backendget_cancelled_exc_class threadlocals)Event) CancelScopecreate_task_group) AsyncBackend) TaskStatus) ) TypeVarTupleUnpackT_RetvalT_coT) covariantPosArgsTc tj}tj}|j |||S#t$r t ddwxYw)z Call a coroutine function from a worker thread. :param func: a coroutine function :param args: positional arguments for the callable :return: the return value of the coroutine function 9This function can only be run from an AnyIO worker threadNtoken)rcurrent_async_backend current_tokenAttributeError RuntimeErrorrun_async_from_threadfuncargs async_backendr,s S/var/www/html/Resume-Scraper/venv/lib/python3.12/site-packages/anyio/from_thread.pyrunr7(s[$:: **  . .tT . GG  G   6A c tj}tj}|j |||S#t$r t ddwxYw)z Call a function in the event loop thread from a worker thread. :param func: a callable :param args: positional arguments for the callable :return: the return value of the callable r*Nr+)rr-r.r/r0run_sync_from_threadr2s r6run_syncr;>s[$:: **  - -dD - FF  G  r8creZdZUded<ded<ded<dZded < dd Zdd Zdd Z dd Zy)_BlockingAsyncContextManagerz Future[T_co] _enter_futurezFuture[bool | None] _exit_futurer _exit_event)NNNzMtuple[type[BaseException] | None, BaseException | None, TracebackType | None]_exit_exc_infoc ||_||_yN) _async_cm_portal)selfasync_cmportals r6__init__z%_BlockingAsyncContextManager.__init__\s" cK t|_|jjd{}|jj | |jjd{|jj|jd{}|S7o#t $r!}|jj|d}~wwxYw7`77#|jj|jd{7}|ccYSxYwwrC) rr@rD __aenter__r> set_result BaseException set_exceptionwait __aexit__rA)rFvalueexcresults r6 run_async_cmz)_BlockingAsyncContextManager.run_async_cmbs 1$wD ..3355E    ) )% 0  ""'') ) ) 44>>33T5H5HIIFM%6     , ,S 1   * J34>>33T5H5HIIIFMsD ,B"B B"D C.C/C3&D CD  B"" C +CC  D CD 'D:C=; DD ct|_|jj|j|_|jj SrC)rr>rEstart_task_soonrUr?rTrFs r6 __enter__z&_BlockingAsyncContextManager.__enter__ys>#X LL889J9JK!!((**rJc|||f|_|jj|jj|j j SrC)rArEcallr@setr?rT)rF&_BlockingAsyncContextManager__exc_type'_BlockingAsyncContextManager__exc_value'_BlockingAsyncContextManager__tracebacks r6__exit__z%_BlockingAsyncContextManager.__exit__~sF )+{B $**../  ''))rJN)rG!AbstractAsyncContextManager[T_co]rHBlockingPortal)return bool | None)rcr&)r]type[BaseException] | Noner^BaseException | Noner_TracebackType | Nonercrd) __name__ __module__ __qualname____annotations__rArIrUrYr`rJr6r=r=Tsr%% 9CQ .+ *.**** *  *rJr=ceZdZddZdddZy)_BlockingPortalTaskStatusc||_yrC)_future)rFfutures r6rIz"_BlockingPortalTaskStatus.__init__s  rJNc:|jj|yrC)rprM)rFrRs r6startedz!_BlockingPortalTaskStatus.starteds &rJ)rqrrC)rRobjectrcNone)rhrirjrIrsrlrJr6rnrns 'rJrnczeZdZdZddZddZddZ ddZddZddZ dddZ dd Z dd Z e dd Ze dd Z dd Ze dd ddZe dd d dZdd d!dZdd d"dZ d#dZy)$rbzLAn object that lets external threads run code in an asynchronous event loop.c2tjSrC)rcreate_blocking_portal)clss r6__new__zBlockingPortal.__new__s "99;;rJc|t|_t|_t |_t |_yrC)r_event_loop_thread_idr _stop_eventr _task_groupr_cancelled_exc_classrXs r6rIzBlockingPortal.__init__s,1:" 7,.$;$=!rJcVK|jjd{|S7wrC)r~rLrXs r6rLzBlockingPortal.__aenter__s())+++  ,s )')cK|jd{|jj|||d{S7)7wrC)stopr~rQ)rFexc_typeexc_valexc_tbs r6rQzBlockingPortal.__aexit__s> iik%%//'6JJJ JsAA$AAAAcv|j td|jtk(r tdy)NzThis portal is not runningz7This method cannot be called from the event loop thread)r|r0rrXs r6_check_runningzBlockingPortal._check_runnings?  % % -;< <  % % 4I  5rJcTK|jjd{y7w)z#Sleep until :meth:`stop` is called.N)r}rPrXs r6sleep_until_stoppedz"BlockingPortal.sleep_until_stoppeds##%%%s (&(cKd|_|jj|r%|jjj yyw)a. Signal the portal to shut down. This marks the portal as no longer accepting new calls and exits from :meth:`sleep_until_stopped`. :param cancel_remaining: ``True`` to cancel all the remaining tasks, ``False`` to let them finish before returning N)r|r}r\r~ cancel_scopecancel)rFcancel_remainings r6rzBlockingPortal.stopsB&*"      ) ) 0 0 2 sA A c\ Kd fd } ||i|}t|rPt5 |jr jn|j ||d{}dddn|}|js|j  d y d y78#1swY4xYw#j $r%|j|jYd yt$r>}|js|j|t|tsYd}~d yd}~wwxYw#d wxYww)Nc|jr5jdtfvrjjyyyrC) cancelledr|rr[r)fscoperFs r6callbackz+BlockingPortal._call_func..callbacks@{{}!;!; D" %,,' "}rJ)rFuture[T_Retval]rcru) r rrradd_done_callbackrMrset_running_or_notify_cancelrNrO isinstance Exception) rFr3r4kwargsrqrretval_or_awaitableretvalrSrs ` @r6 _call_funczBlockingPortal._call_funcs) ( "&"7"7 ./ ]7e'') 00:#66F 77-##%!!&)E&E#7 77(( 2 MMO  / / 1E ##%$$S)c9-. E EsD,B)8B"B#B' B)2!D%D,D,BB&"B))/D"D%D,D"$2DD%D,D""D%%D))D,ct)a% Spawn a new task using the given callable. Implementers must ensure that the future is resolved when the task finishes. :param func: a callable :param args: positional arguments to be passed to the callable :param kwargs: keyword arguments to be passed to the callable :param name: name of the task (will be coerced to a string if not ``None``) :param future: a future that will resolve to the return value of the callable, or the exception raised during its execution )NotImplementedError)rFr3r4rnamerqs r6_spawn_task_from_threadz&BlockingPortal._spawn_task_from_threads *"!rJcyrCrlrFr3r4s r6r[zBlockingPortal.calls rJcyrCrlrs r6r[zBlockingPortal.callsrJc`tt|j|g|jS)a3 Call the given function in the event loop thread. If the callable returns a coroutine object, it is awaited on. :param func: any callable :raises RuntimeError: if the portal is not running or if this method is called from within the event loop thread )rr%rWrTrs r6r[zBlockingPortal.calls-H2d224?$?FFHIIrJN)rcyrCrlrFr3rr4s r6rWzBlockingPortal.start_task_soon$ rJcyrCrlrs r6rWzBlockingPortal.start_task_soon,rrJcd|jt}|j||i|||S)a Start a task in the portal's task group. The task will be run inside a cancel scope which can be cancelled by cancelling the returned future. :param func: the target function :param args: positional arguments passed to ``func`` :param name: name of the task (will be coerced to a string if not ``None``) :return: a future that resolves with the return value of the callable if the task completes successfully, or with the exception raised in the task :raises RuntimeError: if the portal is not running or if this method is called from within the event loop thread :rtype: concurrent.futures.Future[T_Retval] .. versionadded:: 3.0 )rrr)rFr3rr4rs r6rWzBlockingPortal.start_task_soon4s20 $h $$T4T1=rJcdfd }|jtt}t}|j||j ||d|i|||j fS)a Start a task in the portal's task group and wait until it signals for readiness. This method works the same way as :meth:`.abc.TaskGroup.start`. :param func: the target function :param args: positional arguments passed to ``func`` :param name: name of the task (will be coerced to a string if not ``None``) :return: a tuple of (future, task_status_value) where the ``task_status_value`` is the value passed to ``task_status.started()`` from within the target function :rtype: tuple[concurrent.futures.Future[T_Retval], Any] .. versionadded:: 3.0 cjsn|jrjy|jr j |jyt d}j |yy)Nz1Task exited without calling task_status.started())donerr exceptionrOr0)rqrStask_status_futures r6 task_donez,BlockingPortal.start_task..task_donehsl%**,##%&--/%%'&44V5E5E5GH&KC'44S9-rJ task_status)rqrrcru)rrrnrrrT)rFr3rr4rrrrs @r6 start_taskzBlockingPortal.start_taskQso. : %+X/0BC H I& $$T4-1MtUVW$++---rJct||S)a Wrap an async context manager as a synchronous context manager via this portal. Spawns a task that will call both ``__aenter__()`` and ``__aexit__()``, stopping in the middle until the synchronous context manager exits. :param cm: an asynchronous context manager :return: a synchronous context manager .. versionadded:: 2.1 )r=)rFcms r6wrap_async_context_managerz)BlockingPortal.wrap_async_context_manager|s,B55rJrcrbrcru)rrerrfrrgrcrd)F)rboolrcru) r3V<> K,K&K% K  K&3 (J(&( ( ! (  (T"J"&" "  " ! " ".?    :CS JJJ J  J"  ?      4     J    B ).0).). ). & ).V636 %6rJrbceZdZUdZdZded<dZded<ede Z d ed <edd Z ded<edZ ded<edd Z ded<ddZ ddZy)BlockingPortalProvidera= A manager for a blocking portal. Used as a context manager. The first thread to enter this context manager causes a blocking portal to be started with the specific parameters, and the last thread to exit causes the portal to be shut down. Thus, there will be exactly one blocking portal running in this context as long as at least one thread has entered this context manager. The parameters are the same as for :func:`~anyio.run`. :param backend: name of the backend :param backend_options: backend options .. versionadded:: 4.4 asynciostrbackendNdict[str, Any] | Nonebackend_optionsF)initdefault_factoryr_lockr)rdefaultint_leases)rrbrEz-AbstractContextManager[BlockingPortal] | None _portal_cmc(|j5|jDt|j|j|_|jj |_|xjdz c_|j cdddS#1swYyxYw)Nr)rrstart_blocking_portalrrrYrErrXs r6rYz BlockingPortalProvider.__enter__sn ZZ &"7LL$"6"6# $88: LLA L<<   s A1BBc d}|j5|jsJ|jdkDsJ|xjdzc_|js|j}d|_|`ddd|r|j dddyy#1swY xYw)Nrr)rrrrEr`)rFrrr portal_cms r6r`zBlockingPortalProvider.__exit__s DH ZZ !?? "<77 #1d{7swYyxYwwrC)rbrMr)portal_rqs r6 run_portalz)start_blocking_portal..run_portalsb!# 0 0w   g &--/ / / 0 0 0 / 0 0 0 0sTA,AA,%AAA A, A A,AA,A)A A)%A,cjr tjyy#t$r0}j sj |Yd}~yYd}~yd}~wwxYw)N)rr)rrr7rNrrO)rSrrrqrs r6run_blocking_portalz2start_blocking_portal..run_blocking_portals]  . . 0 . 1 ! .{{}((--% .s- A&!A!!A&T)targetdaemonFNr) rrstartrTrNr[rr0join)rrrthreadcancel_remaining_tasksrHrqrs`` @@r6rrs$0 ..&,XF .t rsE" ::% )--VV)8"w++6 : v&  #H ;HDTH H,G 0G9IG G,2*74=2H2*j' 'z6z6z 5151 51pGK1 1/D1)11h$rJ