8iSrSSKrSSKrSSKJr SSKJr "SS\5r"S S \5r "S S \ 5r "S S\ 5r Sr /SQr g)zEModule implementing the Pool for :mod:``requests_toolbelt.threaded``.N)thread)queuec\rSrSrSrSSS\R 4SjrSr\ S5r \ SSj5r Sr S r S rS rS rS rg)Pool aPool that manages the threads containing sessions. :param queue: The queue you're expected to use to which you should add items. :type queue: queue.Queue :param initializer: Function used to initialize an instance of ``session``. :type initializer: collections.Callable :param auth_generator: Function used to generate new auth credentials for the session. :type auth_generator: collections.Callable :param int num_process: Number of threads to create. :param session: :type session: requests.Session Nc *Uc[R"5=(d SnUS:a [S5eXl[R "5Ul[R "5UlX@lU=(d [Ul U=(d [Ul XPl [UR5Vs/sHHn[R"UR!5URUR UR5PMJ snUlgs snf)Nrz)Number of processes should at least be 1.)multiprocessing cpu_count ValueError _job_queuerQueue_response_queue _exc_queue _processes _identity _initializer_auth_sessionranger SessionThread _new_session_pool)self job_queue initializerauth_generator num_processessession_s o/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/requests_toolbelt/threaded/pool.py__init__ Pool.__init__s  +557<1M 1 HI I#${{}++-''49#0y  4??+ ,  !2!2!4doo!%!5!5t H+   s8ADc^URURUR555$N)rrr)rs r"rPool._new_session0s"zz$++DMMO<==c [R"5nUHnURUR5 M U"SSU0UD6$)aCreate a :class:`~Pool` from an :class:`~ThreadException`\ s. Provided an iterable that provides :class:`~ThreadException` objects, this classmethod will generate a new pool to retry the requests that caused the exceptions. :param exceptions: Iterable that returns :class:`~ThreadException` :type exceptions: iterable :param kwargs: Keyword arguments passed to the :class:`~Pool` initializer. :returns: An initialized :class:`~Pool` object. :rtype: :class:`~Pool` r)rrputrequest_kwargs)cls exceptionskwargsrexcs r"from_exceptionsPool.from_exceptions3s@ KKM C MM#,, -1Y1&11r(c SS0nURU=(d 05 [R"5nUH7nUR5nURSU05 UR U5 M9 U"SSU0UD6$)aCreate a :class:`~Pool` from an iterable of URLs. :param urls: Iterable that returns URLs with which we create a pool. :type urls: iterable :param dict request_kwargs: Dictionary of other keyword arguments to provide to the request method. :param kwargs: Keyword arguments passed to the :class:`~Pool` initializer. :returns: An initialized :class:`~Pool` object. :rtype: :class:`~Pool` methodGETurlrr*)updaterrcopyr+)r-urlsr,r/ request_dictrr6jobs r" from_urlsPool.from_urlsIsu!%( N0b1KKM C##%C JJs| $ MM#  1Y1&11r(c#@# UR5nUcgUv M7f)z_Iterate over all the exceptions in the pool. :returns: Generator of :class:`~ThreadException` N) get_exception)rr0s r"r.Pool.exceptionsbs* $$&C{I cURR5up[X5$![Ra gf=f)zCGet an exception from the pool. :rtype: :class:`~ThreadException` N)r get_nowaitThreadExceptionrEmpty)rrequestr0s r"r?Pool.get_exceptionms@  1!__779NW#70 0{{  )AAcURR5up[X5$![Ra gf=f)z@Get a response from the pool. :rtype: :class:`~ThreadResponse` N)rrCThreadResponserrE)rrFresponses r" get_responsePool.get_responseysC  5"&"6"6"A"A"C W"'4 4{{  rHc#@# UR5nUcgUv M7f)z]Iterate over all the responses in the pool. :returns: Generator of :class:`~ThreadResponse` N)rL)rresps r" responsesPool.responsess* $$&D|J rAcJURHnUR5 M g)z*Join all the threads to the master thread.N)rjoin)rsession_threads r"join_all Pool.join_alls"jjN    !)r()rrrrrrrrr&)__name__ __module__ __qualname____firstlineno____doc__requestsSessionr#r classmethodr1r<r.r?rLrPrU__static_attributes__r*r(r"rr sd"/34#X-=-= *>22*220  1 5 "r(rc\rSrSrSrSrSrg) ThreadProxyNc[RnXR;aU"XR5n[ X15$U"X5$)z/Proxy attribute accesses to the proxied object.)object__getattribute__attrs proxied_attrgetattr)rattrgetrKs r" __getattr__ThreadProxy.__getattr__s<%% zz !4!2!23H8* *t? "r(r*)rWrXrYrZrgrkr_r*r(r"raras L#r(rac6\rSrSrSrSr\"SS/5rSrSr g)rJa&A wrapper around a requests Response object. This will proxy most attribute access actions to the Response object. For example, if you wanted the parsed JSON from the response, you might do: .. code-block:: python thread_response = pool.get_response() json = thread_response.json() rKr,cXlX lgr&r,rK)rr,rKs r"r#ThreadResponse.__init__s , r(rpN rWrXrYrZr[rg frozensetrfr#r_r*r(r"rJrJs# L '4 5E!r(rJc6\rSrSrSrSr\"SS/5rSrSr g)rDa%A wrapper around an exception raised during a request. This will proxy most attribute access actions to the exception object. For example, if you wanted the message from the exception, you might do: .. code-block:: python thread_exc = pool.get_exception() msg = thread_exc.message exceptionr,cXlX lgr&)r,rv)rr,rvs r"r#ThreadException.__init__s ,"r()rvr,Nrrr*r(r"rDrDs# L '5 6E#r(rDcU$r&r*) session_objs r"rrs r()rDrJr)r[r r\r_compatrrdrrarJrDr__all__r*r(r"r~sSKJ"6J"Z #& #![!,#k#, 8r(