8j?)JddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZmZerddlmZdd lmZdd lmZej2ej4ej6ej8fZ ed Gd d eZed GddeZy)) annotations) TYPE_CHECKINGN)override)DEFAULT_MAX_RETRIES!DEFAULT_MIN_DELAY_BETWEEN_RETRIESDEFAULT_TIMEOUT_LONGDEFAULT_TIMEOUT_MAXDEFAULT_TIMEOUT_MEDIUMDEFAULT_TIMEOUT_SHORT) docs_group) HttpClientHttpClientAsync) timedelta)ClientStatistics)HttpCompressorz HTTP clientsc eZdZdZdeeeeee dddd d fdZ e d fd Z e d dZ e d dZe d dZxZS) ImpitHttpClientaSynchronous HTTP client for the Apify API built on top of [Impit](https://github.com/apify/impit). Impit is a high-performance HTTP client written in Rust that provides browser-like TLS fingerprints, automatic header ordering, and HTTP/2 support. This client wraps `impit.Client` and adds automatic retries with exponential backoff for rate-limited (HTTP 429) and server error (HTTP 5xx) responses. N token timeout_shorttimeout_medium timeout_long timeout_max max_retriesmin_delay_between_retries statisticsheadershttp_compressorc nt |||||||||| |  tjd|_y)aInitialize the Impit-based synchronous HTTP client. Args: token: Apify API token for authentication. timeout_short: Default timeout for short-duration API operations (simple CRUD operations, ...). timeout_medium: Default timeout for medium-duration API operations (batch operations, listing, ...). timeout_long: Default timeout for long-duration API operations (long-polling, streaming, ...). timeout_max: Maximum timeout cap for any single request attempt, including tier and per-call timeouts. max_retries: Maximum number of retry attempts for failed requests. min_delay_between_retries: Minimum delay between retries (increases exponentially with each attempt). statistics: Statistics tracker for API calls. Created automatically if not provided. headers: Additional HTTP headers to include in all requests. http_compressor: Compressor used to compress request bodies. Defaults to `GzipHttpCompressor`. rTfollow_redirectsN)super__init__impitClient _impit_client selfrrrrrrrrrr __class__s W/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/http_clients/_impit.pyr#zImpitHttpClient.__init__3sH8 ')%##&?!+  #\\4@cZt||xst|tjSNr"is_timeout_error isinstancer$TimeoutExceptionr(excr)s r*r/z ImpitHttpClient.is_timeout_error^%w',W 3@V@V0WWr+c\t|tjxrt|t Sr-r0r$ HTTPError_PERMANENT_ERRORSr(r3s r*is_retryable_transport_errorz,ImpitHttpClient.is_retryable_transport_errorb%#u/Z 3HY8Z4ZZr+c>|jjdddy)a Release resources owned by this client. Delegates to Impit's own teardown, which releases nothing and leaves the client usable, because Impit doesn't expose a way to close its connection pool. Routing through it keeps this client correct once Impit does. N)r&__exit__r(s r*closezImpitHttpClient.closeks ##D$5r+cP|dn|}|jj||||||SNiQ)methodurlrcontenttimeoutstream)r&requestr(rBrCrrDrErF impit_timeouts r* send_requestzImpitHttpClient.send_requestus?#*/w !!))! *  r+rz str | NonerrrrrrrrrintrrrzClientStatistics | Nonerzdict[str, str] | NonerzHttpCompressor | NonereturnNoner3 ExceptionrMboolrMrNrBstrrCrTrzdict[str, str]rDz bytes | NonerEz float | NonerFrQrMzimpit.Response)__name__ __module__ __qualname____doc__r r rr rrr#rr/r:r?rJ __classcell__r)s@r*rr*sB!#8$:"6!4./P.2)-15)A)A! )A " )A  )A)A)A$-)A,)A')A/)A )AVXX[[66             r+rc eZdZdZdeeeeee dddd d fdZ e d fd Z e d dZ e d dZe d dZxZS) ImpitHttpClientAsyncaAsynchronous HTTP client for the Apify API built on top of [Impit](https://github.com/apify/impit). Impit is a high-performance HTTP client written in Rust that provides browser-like TLS fingerprints, automatic header ordering, and HTTP/2 support. This client wraps `impit.AsyncClient` and adds automatic retries with exponential backoff for rate-limited (HTTP 429) and server error (HTTP 5xx) responses. Nrc nt |||||||||| |  tjd|_y)aInitialize the Impit-based asynchronous HTTP client. Args: token: Apify API token for authentication. timeout_short: Default timeout for short-duration API operations (simple CRUD operations, ...). timeout_medium: Default timeout for medium-duration API operations (batch operations, listing, ...). timeout_long: Default timeout for long-duration API operations (long-polling, streaming, ...). timeout_max: Maximum timeout cap for any single request attempt, including tier and per-call timeouts. max_retries: Maximum number of retry attempts for failed requests. min_delay_between_retries: Minimum delay between retries (increases exponentially with each attempt). statistics: Statistics tracker for API calls. Created automatically if not provided. headers: Additional HTTP headers to include in all requests. http_compressor: Compressor used to compress request bodies. Defaults to `GzipHttpCompressor`. rTr N)r"r#r$ AsyncClient_impit_async_clientr's r*r#zImpitHttpClientAsync.__init__sJ8 ')%##&?!+  $)#4#4d#K r+cZt||xst|tjSr-r.r2s r*r/z%ImpitHttpClientAsync.is_timeout_errorr4r+c\t|tjxrt|t Sr-r6r9s r*r:z1ImpitHttpClientAsync.is_retryable_transport_errorr;r+cZK|jjdddd{y7w)zuRelease resources owned by this client. See `ImpitHttpClient.close` for what Impit's teardown does. N)r_ __aexit__r>s r*aclosezImpitHttpClientAsync.acloses& &&00tTBBBs !+)+clK|dn|}|jj||||||d{S7wrA)r_rGrHs r*rJz!ImpitHttpClientAsync.send_requestsM#*/w --55! 6    s +424rKrOrRrS)rUrVrWrXr r rr rrr#rr/r:rdrJrYrZs@r*r\r\sD!#8$:"6!4./P.2)-15)L)L! )L " )L  )L)L)L$-)L,)L')L/)L )LVXX[[CC             r+r\) __future__rtypingrr$typing_extensionsrapify_client._constsrrrr r r apify_client._docsr apify_client.http_clients._baser rdatetimerapify_client._statisticsr#apify_client.http_compressors._baserLocalProtocolErrorUnsupportedProtocolTooManyRedirectsHTTPStatusErrorr8rr\r+r*rts" &*G"9B      o N` j` ` F N\ ?\ \ r+