F2jUdZddlmZddlZddlZddlmZmZmZddl m Z ddl m Z m Z mZddlmZdd lmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!ej"d d Z#d e$d <ej"dd Z%d e$d<edZ&de$d<ej'dddddddddddddddddbd:Z(ej'dddddddddddddddddcd=Z(dddddded>ddddddeddddAZ(ej' deddddddddddddB dfdEZ)ej' deddddddddddddB dgdFZ) dhddded>dddddedB didGZ)ej'dddddddddddddH djdJZ*ej'ddddddddddddK dgdLZ*dddded>dddddedH didMZ*ej'dddddddddddddH djdNZ+ej'ddddddddddddK dgdOZ+ddddedPdddddedH didQZ+ej' dkddddddddddddddR dldSZ,ej' dkdddddddddddddT dmdUZ, dnddddded>dddddedR dodVZ,ej' dedddddddddddddddWdldXZ-ej' deddddddddddddddY dmdZZ- dhdddddded>dddddedWdod[Z-ej' dedddddddddddddddWdld\Z.ej' deddddddddddddddY dmd]Z. dhdddddded>dddddedWdod^Z.ej'dddddddddddddH djd_Z/ej'ddddddddddddK dgd`Z/dddded>dddddedH didaZ/dS)pz requests.api ~~~~~~~~~~~~ This module implements the Requests API. :copyright: (c) 2012 by Kenneth Reitz. :license: Apache2, see LICENSE for more details. ) annotationsN)DEFAULT_RETRIESREAD_DEFAULT_TIMEOUTWRITE_DEFAULT_TIMEOUT) AsyncSession) AsyncResponsePreparedRequestResponse)AsyncQuicSharedCache) AsyncBodyType AsyncHookTypeAsyncHttpAuthenticationTypeBodyTypeCacheLayerAltSvcType CookiesType HeadersTypeHttpAuthenticationTypeHttpMethodTypeMultiPartFilesAltTypeMultiPartFilesType ProxyTypeQueryParameterType RetryType TimeoutTypeTLSClientCertType TLSVerifyType ocsp_cache)defaultz)contextvars.ContextVar[typing.Any | None]_SHARED_OCSP_CACHE crl_cache_SHARED_CRL_CACHEi0)max_sizer_SHARED_QUIC_CACHE.)paramsdataheaderscookiesfilesauthtimeoutallow_redirectsproxieshooksstreamverifycertjsonretriesmethodrurlstrr%QueryParameterType | Noner&BodyType | AsyncBodyType | Noner'HeadersType | Noner(CookiesType | Noner)1MultiPartFilesType | MultiPartFilesAltType | Noner*;HttpAuthenticationType | AsyncHttpAuthenticationType | Noner+TimeoutType | Noner,boolr-ProxyType | Noner.0AsyncHookType[PreparedRequest | Response] | Noner/typing.Literal[False] | Noner0TLSVerifyType | Noner1TLSClientCertType | Noner2typing.Any | Noner3rreturnr c KdSNr4r5r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3s Z/home/thesage/.hermes/hermes-agent/venv/lib/python3.11/site-packages/niquests/async_api.pyrequestrK-s (styping.Literal[True]r c KdSrGrHrIs rJrKrKDs (CrLT bool | NoneResponse | AsyncResponsecfKtt|dd4d{V }t|_t |_ ||||||||||| | | | | ||d{V t&|jt|jt &|jt |jcdddd{VS#t&|jt|jt '|j!t |jwwwxYw#1d{VswxYwYdS)a Constructs and sends a :class:`Request `. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param method: method for the new :class:`Request` object: ``GET``, ``OPTIONS``, ``HEAD``, ``POST``, ``PUT``, ``PATCH``, or ``DELETE``. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param json: (optional) A JSON serializable Python object to send in the body of the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param files: (optional) Dictionary of ``'name': file-like-objects`` (or ``{'name': file-tuple}``) for multipart encoding upload. ``file-tuple`` can be a 2-tuple ``('filename', fileobj)``, 3-tuple ``('filename', fileobj, 'content_type')`` or a 4-tuple ``('filename', fileobj, 'content_type', custom_headers)``, where ``'content_type'`` is a string defining the content type of the given file and ``custom_headers`` a dict-like object containing additional headers to add for the file. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` Usage:: >>> import niquests >>> req = await niquests.arequest('GET', 'https://httpbin.org/get') >>> req N)quic_cache_layerr3keepalive_delaykeepalive_idle_window) rr$r get _ocsp_cacher" _crl_cacherKset)r4r5r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3sessions rJrKrK[sQN+Wdjn:::::::: 04466.2244 : ! &"%%''/G4G4S"&&w':;;; $$&&.73E3Q!%%g&89999::::::::::::::2"%%''/G4G4S"&&w':;;; $$&&.73E3Q!%%g&89999/3Q7::::::::::::::::s+=F  )D A>F BFF  F*-F*) r'r(r*r+r,r-r.r0r/r1r3kwargs typing.Anyc  KdSrGrHr5r%r'r(r*r+r,r-r.r0r/r1r3rZs rJrUrU "srLc  KdSrGrHr]s rJrUrU "CrLc HKtd|f|||||||| | | || d | d{VS)a Sends a GET request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` GET r%r'r(r*r+r,r-r0r/r1r.r3NrKr]s rJrUrUsy^   '        rL) r%r'r(r*r+r,r-r.r0r/r1r3,typing.Literal[False] | typing.Literal[None]c  KdSrGrHr]s rJoptionsrg+r^rL) r%r'r(r*r+r,r-r.r0r1r3c  KdSrGrHr]s rJrgrg?r`rLc HKtd|f|||||||| | | || d | d{VS)aSends an OPTIONS request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` OPTIONSrcNrdr]s rJrgrgSsy\  '        rLc  KdSrGrHr]s rJheadrlr^rLc  KdSrGrHr]s rJrlrlr`rLFc HKtd|f|||||||| | | || d | d{VS)aSends a HEAD request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``False``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` HEAD) r,r%r'r(r*r+r-r0r/r1r.r3Nrdr]s rJrlrlsy\ (         rL) r%r'r(r)r*r+r,r-r.r0r/r1r3c  KdSrGrHr5r&r2r%r'r(r)r*r+r,r-r.r0r/r1r3s rJpostrr &srL) r%r'r(r)r*r+r,r-r.r0r1r3c  KdSrGrHrqs rJrrrr &CrLc JKtd|f||||||||| | | | || |dd{VS)a Sends a POST request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param data: (optional) Dictionary, list of tuples, bytes, or (awaitable or not) file-like object to send in the body of the :class:`Request`. :param json: (optional) A JSON serializable Python object to send in the body of the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param files: (optional) Dictionary of ``'name': file-like-objects`` (or ``{'name': file-tuple}``) for multipart encoding upload. ``file-tuple`` can be a 2-tuple ``('filename', fileobj)``, 3-tuple ``('filename', fileobj, 'content_type')`` or a 4-tuple ``('filename', fileobj, 'content_type', custom_headers)``, where ``'content_type'`` is a string defining the content type of the given file and ``custom_headers`` a dict-like object containing additional headers to add for the file. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` POST)r&r2r%r'r(r)r*r+r,r-r0r/r1r.r3Nrdrqs rJrrrr)sxr   ' #      rL)r2r%r'r(r)r*r+r,r-r.r0r/r1r3c KdSrGrHrqs rJputrywrsrL) r2r%r'r(r)r*r+r,r-r.r0r1r3c KdSrGrHrqs rJryryrurLcJKtd|f||||||||| | | | || |dd{VS)a Sends a PUT request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param data: (optional) Dictionary, list of tuples, bytes, or (awaitable or not) file-like object to send in the body of the :class:`Request`. :param json: (optional) A JSON serializable Python object to send in the body of the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param files: (optional) Dictionary of ``'name': file-like-objects`` (or ``{'name': file-tuple}``) for multipart encoding upload. ``file-tuple`` can be a 2-tuple ``('filename', fileobj)``, 3-tuple ``('filename', fileobj, 'content_type')`` or a 4-tuple ``('filename', fileobj, 'content_type', custom_headers)``, where ``'content_type'`` is a string defining the content type of the given file and ``custom_headers`` a dict-like object containing additional headers to add for the file. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` PUTr&r%r2r'r(r)r*r+r,r-r0r/r1r.r3Nrdrqs rJryrysxr    ' #      rLc KdSrGrHrqs rJpatchrrsrLc KdSrGrHrqs rJrrrurLcJKtd|f||||||||| | | | || |dd{VS)a Sends a PATCH request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param data: (optional) Dictionary, list of tuples, bytes, or (awaitable or not) file-like object to send in the body of the :class:`Request`. :param json: (optional) A JSON serializable Python object to send in the body of the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param files: (optional) Dictionary of ``'name': file-like-objects`` (or ``{'name': file-tuple}``) for multipart encoding upload. ``file-tuple`` can be a 2-tuple ``('filename', fileobj)``, 3-tuple ``('filename', fileobj, 'content_type')`` or a 4-tuple ``('filename', fileobj, 'content_type', custom_headers)``, where ``'content_type'`` is a string defining the content type of the given file and ``custom_headers`` a dict-like object containing additional headers to add for the file. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` PATCHr}Nrdrqs rJrrsxr   ' #      rLc  KdSrGrHr]s rJdeleterkr^rLc  KdSrGrHr]s rJrrr`rLc HKtd|f|||||||| | | || d | d{VS)aSends a DELETE request. This does not keep the connection alive. Use an :class:`AsyncSession` to reuse the connection. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param auth: (optional) Auth tuple to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :param allow_redirects: (optional) Boolean. Enable/disable GET/OPTIONS/POST/PUT/PATCH/DELETE/HEAD redirection. Defaults to ``True``. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a path passed as a string or os.Pathlike object, in which case it must be a path to a CA bundle to use. Defaults to ``True``. It is also possible to put the certificates (directly) in a string or bytes. :param stream: (optional) if ``False``, the response content will be immediately downloaded. Otherwise, the response will be of type :class:`AsyncResponse ` so that it will be awaitable. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair, or ('cert', 'key', 'key_password'). :param hooks: (optional) Register functions that should be called at very specific moment in the request lifecycle. :param retries: (optional) If integer, determine the number of retry in case of a timeout or connection error. Otherwise, for fine gained retry, use directly a ``Retry`` instance from urllib3. :return: :class:`Response ` object if stream=None or False. Otherwise :class:`AsyncResponse ` DELETErcNrdr]s rJrrsy\  '        rL)$r4rr5r6r%r7r&r8r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r/rAr0rBr1rCr2rDr3rrEr )$r4rr5r6r%r7r&r8r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r/rMr0rBr1rCr2rDr3rrEr )$r4rr5r6r%r7r&r8r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r/rOr0rBr1rCr2rDr3rrErP).)r5r6r%r7r'r9r(r:r*r<r+r=r,r>r-r?r.r@r0rBr/rAr1rCr3rrZr[rEr )r5r6r%r7r'r9r(r:r*r<r+r=r,r>r-r?r.r@r0rBr/rMr1rCr3rrZr[rEr rG)r5r6r%r7r'r9r(r:r*r<r+r=r,r>r-r?r.r@r0rBr/rOr1rCr3rrZr[rErP)r5r6r%r7r'r9r(r:r*r<r+r=r,r>r-r?r.r@r0rBr/rer1rCr3rrZr[rEr )..)"r5r6r&r8r2rDr%r7r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r0rBr/rer1rCr3rrEr )"r5r6r&r8r2rDr%r7r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r0rBr/rMr1rCr3rrEr )NN)"r5r6r&r8r2rDr%r7r'r9r(r:r)r;r*r<r+r=r,r>r-r?r.r@r0rBr/rOr1rCr3rrErP)0__doc__ __future__r contextvarstyping _constantrrr async_sessionrmodelsr r r structuresr r rrrrrrrrrrrrrrrr ContextVarr __annotations__r"r$overloadrKrUrgrlrrryrrrHrLrJrs #""""" SSSSSSSSSS''''''<<<<<<<<<<,,,,,,(AW @VWcmq@r@r@rrrrr?U{?UVako?p?p?ppppp+?+?+P+P+PPPPP ),,/"%"%?BHK"% #>A+.#&%(!%, ),,/"%"%?BHK"% #>A#&#&%(!%4)-,0"&"&?CHL"7 $>B#'%)"(%c:c:c:c:c:c:L),#&"%HK"% #>A#&+.%(&),#&"%HK"% #>A#&#&%(*)-?#'"&HL"6 $>B#'%)(??????D),"%"%HK"% #>A#&;>%(&),"%"%HK"% #>A#&%(,)-"&"&HL"6 $>B#'%)(>>>>>>B),"%"%HK"% #>A#&;>%(&),"%"%HK"% #>A#&%(,)-"&"&HL"6! $>B#'%)(>>>>>>B-0! ),"%"%?BHK"% #>A#&;>%(#*-0! ),"%"%?BHK"% #>A#&%(#.-1"K )-"&"&?CHL"7 $>B#'%)(#KKKKKK\-0"(+"%"%?BHK"% #>A#&;>%(#*-0"(+"%"%?BHK"% #>A#&%(#.-1K#(,"&"&?CHL"7 $>B#'%)(#KKKKKK\-0"(+"%"%?BHK"% #>A#&;>%(#*-0"(+"%"%?BHK"% #>A#&%(#.-1K#(,"&"&?CHL"7 $>B#'%)(#KKKKKK\),"%"%HK"% #>A#&;>%(&),"%"%HK"% #>A#&%(,)-"&"&HL"7 $>B#'%)(>>>>>>>>rL