j>ddlmZddlmZmZmZmZddlmZddl m Z ddl m Z ddl mZddlmZmZdd lmZmZd d lmZd d lmZerdd lmZGddeZy))deepcopy)Any Awaitable TYPE_CHECKINGUnion)Self)AsyncPipelineClient)AzureKeyCredential)policies)AsyncHttpResponse HttpRequest) Deserializer Serializer)'ContentUnderstandingClientConfiguration)*_ContentUnderstandingClientOperationsMixin)AsyncTokenCredentialc zeZdZdZdedeedfdeddfdZd d d e d e dede e fd Z ddZdefdZdeddfdZy)ContentUnderstandingClienta ContentUnderstandingClient. :param endpoint: Content Understanding service endpoint. Required. :type endpoint: str :param credential: Credential used to authenticate requests to the service. Is either a key credential type or a token credential type. Required. :type credential: ~azure.core.credentials.AzureKeyCredential or ~azure.core.credentials_async.AsyncTokenCredential :keyword api_version: The API version to use for this operation. Known values are "2025-11-01" and None. Default value is "2025-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present. endpoint credentialrkwargsreturnNc *d}td||d||_|jdd}|'tjdi||jj |jj |jjtjdi||jj|jj|jj|jj|jjtjdi||jjrtjdi|nd|jj g }t#d||d||_t'|_t+|_d|j(_y)Nz{endpoint}/contentunderstanding)rrr )base_urlr F)r_configpopr RequestIdPolicyheaders_policyuser_agent_policy proxy_policyContentDecodePolicyredirect_policy retry_policyauthentication_policycustom_hook_policylogging_policyDistributedTracingPolicySensitiveHeaderCleanupPolicyhttp_logging_policyr _clientr _serializer _deserializeclient_side_validation)selfrrr _endpoint _policiess j/root/aria/tools/markitdown-venv/lib/python3.12/site-packages/azure/ai/contentunderstanding/aio/_client.py__init__z#ContentUnderstandingClient.__init__+sU 6 > * 8>  JJz40  ((262 ++ .. )),,6v6 ,, )) 22 // ++11;F;||3399CFC 00#I&-@- - 6<-  %,(N16.F)streamrequestr7c t|}d|jjd|jjddi}|j j |jfi||_|j j|fd|i|S)a6Runs the network request through the client's chained policies. >>> from azure.core.rest import HttpRequest >>> request = HttpRequest("GET", "https://www.example.org/") >>> response = await client.send_request(request) For more information on this code flow, see https://aka.ms/azsdk/dpcodegen/python/send_request :param request: The network request you want to make. Required. :type request: ~azure.core.rest.HttpRequest :keyword bool stream: Whether the response payload will be streamed. Defaults to False. :return: The response of your network call. Does not do error handling on your response. :rtype: ~azure.core.rest.AsyncHttpResponse rzself._config.endpointstrT) skip_quoter7)rr.urlrrr- format_url send_request)r1r8r7r request_copypath_format_argumentss r4r>z'ContentUnderstandingClient.send_requestSs( ( ++')>)>RV,!  34<<22    5 )t||((OfOOOr6cTK|jjd{y7wN)r-closer1s r4rCz ContentUnderstandingClient.closessll  """s (&(cVK|jjd{|S7wrB)r- __aenter__rDs r4rFz%ContentUnderstandingClient.__aenter__vs&ll%%'''  (s )') exc_detailscRK|jj|d{y7wrB)r- __aexit__)r1rGs r4rIz$ContentUnderstandingClient.__aexit__zs $dll$$k222s '%')rN)__name__ __module__ __qualname____doc__r:rr rr5r boolrr r>rCrrFrIrr6r4rrs &7&7,.DDE&7 &7  &7R7<P"P/3PGJP $ %P@#$3C3D3r6rN)copyrtypingrrrrtyping_extensionsr azure.corer azure.core.credentialsr azure.core.pipeliner azure.core.restr r _utils.serializationrr_configurationr _operationsrazure.core.credentials_asyncrrrr6r4rZs=77"*5(:;CCAa3!Ka3r6