(ph(SSKrSSKJr SSKrSSKrSSKJrJr SSKJ r J r SSK J r SSK Jr SSKJr SSKJr S r\S 5r"S S 5rg!\a S rNf=f)N)asynccontextmanager)MappingOptional)_exponential_backoff exceptions) transport) Credentials) TimeoutError)RequestTFc^^^# [R"5mUmUU4SjmUU4SjnU7v T"5 g!T"5 f=f7f)a timeout_guard is an asynchronous context manager to apply a timeout to an asynchronous block of code. Args: timeout (float): The time in seconds before the context manager times out. Raises: google.auth.exceptions.TimeoutError: If the code within the context exceeds the provided timeout. Usage: async with timeout_guard(10) as with_timeout: await with_timeout(async_function()) cl>[R"5T- nTU- nUS::a[STS35eU$)Nrz3Context manager exceeded the configured timeout of s.)time monotonicr )elapsed remainingstart total_timeouts U/var/www/html/venv/lib/python3.13/site-packages/google/auth/aio/transport/sessions.py_remaining_time&timeout_guard.._remaining_time4sG.."U*!G+ >Em_TVW c># T"5n[R"X5IShvN nU$N![R[4an[SUSTS35UeSnAff=f7f)NzThe operation z$ exceeded the configured timeout of r)asynciowait_forr )cororresponseerrs r with_timeout#timeout_guard..with_timeout=sn ')I$--d>>HO?$$l3  &J=/Y[\  s1A# .,.A#.A AA  A#N)rr)timeoutrrrrs @@@r timeout_guardr""s< NN EM s&A9A AAc*\rSrSrSrSS\S\\R4Sjjr SS\R\R4S\ S\ S \\ S \\ \ \ 4S \S \S \R4Sjjr\R$"\5SS\R\R4S\ S \\ S \\ \ \ 4S \S \S \R4 Sjj5r\R$"\5SS\R\R4S\ S \\ S \\ \ \ 4S \S \S \R4 Sjj5r\R$"\5SS\R\R4S\ S \\ S \\ \ \ 4S \S \S \R4 Sjj5r\R$"\5SS\R\R4S\ S \\ S \\ \ \ 4S \S \S \R4 Sjj5r\R$"\5SS\R\R4S\ S \\ S \\ \ \ 4S \S \S \R4 Sjj5rSSjrSrg)AsyncAuthorizedSessionNa;This is an asynchronous implementation of :class:`google.auth.requests.AuthorizedSession` class. We utilize an instance of a class that implements :class:`google.auth.aio.transport.Request` configured by the caller or otherwise default to `google.auth.aio.transport.aiohttp.Request` if the external aiohttp package is installed. A Requests Session class with credentials. This class is used to perform asynchronous requests to API endpoints that require authorization:: import aiohttp from google.auth.aio.transport import sessions async with sessions.AsyncAuthorizedSession(credentials) as authed_session: response = await authed_session.request( 'GET', 'https://www.googleapis.com/storage/v1/b') The underlying :meth:`request` implementation handles adding the credentials' headers to the request and refreshing credentials as needed. Args: credentials (google.auth.aio.credentials.Credentials): The credentials to add to the request. auth_request (Optional[google.auth.aio.transport.Request]): An instance of a class that implements :class:`~google.auth.aio.transport.Request` used to make requests and refresh credentials. If not passed, an instance of :class:`~google.auth.aio.transport.aiohttp.Request` is created. Raises: - google.auth.exceptions.TransportError: If `auth_request` is `None` and the external package `aiohttp` is not installed. - google.auth.exceptions.InvalidType: If the provided credentials are not of type `google.auth.aio.credentials.Credentials`. N credentials auth_requestc[U[5(d#[R"S[ U5S35eXlUnU(d[ (a [5nUc[R"S5eX0l g)Nz#The configured credentials of type zJ are invalid and must be of type `google.auth.aio.credentials.Credentials`zv`auth_request` must either be configured or the external package `aiohttp` must be installed to use the default value.) isinstancer r InvalidTypetype _credentialsAIOHTTP_INSTALLEDAiohttpRequestTransportError _auth_request)selfr&r'r0s r__init__AsyncAuthorizedSession.__init__ts+{33((5d;6G5HIST ($ !2!2*,M  ++I +rmethodurldataheadersmax_allowed_timer!returnc # [R"[RS9n[ U5IShvN n U "UR R URXU55IShvN UShvN n U "UR"X!X4U40UD65IShvN n U R[R;dML SSS5IShvN W $NNgN^N= NN!,IShvN (df  W $=f7f)a Args: method (str): The http method used to make the request. url (str): The URI to be requested. data (Optional[bytes]): The payload or body in HTTP request. headers (Optional[Mapping[str, str]]): Request headers. timeout (float): The amount of time in seconds to wait for the server response with each individual request. max_allowed_time (float): If the method runs longer than this, a ``Timeout`` exception is automatically raised. Unlike the ``timeout`` parameter, this value applies to the total method execution time, even if multiple requests are made under the hood. Mind that it is not guaranteed that the timeout error is raised at ``max_allowed_time``. It might take longer, for example, if an underlying request takes a lot of time, but the request itself does not timeout, e.g. if a large file is being transmitted. The timout error will be raised after such request completes. Returns: google.auth.aio.transport.Response: The HTTP response. Raises: google.auth.exceptions.TimeoutError: If the method does not complete within the configured `max_allowed_time` or the request exceeds the configured `timeout`. )total_attemptsN) rAsyncExponentialBackoffrDEFAULT_MAX_RETRY_ATTEMPTSr"r,before_requestr0 status_codeDEFAULT_RETRYABLE_STATUS_CODES) r1r4r5r6r7r8r!kwargsretriesr_rs rrequestAsyncAuthorizedSession.requestsR'>>$?? !!122l!!00&&W  # a!-&&sD7UfU"''y/W/WW323  #322s2C6CC61C)C*C0C4C5C8CC C<C= C6C C6CCCCC6C3!C$ " C3.C6cJ# UR"SXX4U40UD6IShvN $N7f)NGETrDr1r5r6r7r8r!rAs rgetAsyncAuthorizedSession.get3\\ 3g DJ    #!#cJ# UR"SXX4U40UD6IShvN $N7f)NPOSTrHrIs rpostAsyncAuthorizedSession.posts3\\ Cw' EK    rMcJ# UR"SXX4U40UD6IShvN $N7f)NPUTrHrIs rputAsyncAuthorizedSession.putrLrMcJ# UR"SXX4U40UD6IShvN $N7f)NPATCHrHrIs rpatchAsyncAuthorizedSession.patchs3\\ S7 FL    rMcJ# UR"SXX4U40UD6IShvN $N7f)NDELETErHrIs rdeleteAsyncAuthorizedSession.deletes3\\ cG GM    rMcT# URR5IShvN gN7f)z, Close the underlying auth request session. N)r0close)r1s rr_AsyncAuthorizedSession.closes  &&(((s (&()r0r,)N)r9N)__name__ __module__ __qualname____firstlineno____doc__r rrr r2_DEFAULT_TIMEOUT_SECONDSstrbytesrfloatResponserD functoolswrapsrJrPrTrXr\r___static_attributes__rrr$r$Ns]#LUY+&+6>y?P?P6Q+*!%/3"+"D"D";;;;;uo ; '#s(+, ;  ;;   ;z__W!%/3"+"D"D";;    uo  '#s(+,             __W!%/3"+"D"D";;    uo  '#s(+,             __W!%/3"+"D"D";;    uo  '#s(+,             __W!%/3"+"D"D";;    uo  '#s(+,             __W!%/3"+"D"D";;    uo  '#s(+,             )rr$)r contextlibrrkrtypingrr google.authrrgoogle.auth.aiorgoogle.auth.aio.credentialsr google.auth.exceptionsr !google.auth.aio.transport.aiohttpr r.r- ImportErrorr"r$rnrrrwsi* $8%3/K ((V~)~)asAAA