o ưi(@sdZddlmZddlZddlmZmZmZmZddl Z ddl m Z ddl Z ddl mZddlmZddlmZdd lmZmZmZmZdd lmZd d lmZd d lmZer_ddlm Z neZ Gddde Z!GdddeZ"dS)zW Bedrock Image Edit Handler Handles image edit requests for Bedrock stability models. ) annotationsN) TYPE_CHECKINGAnyOptionalUnion) BaseModel)verbose_logger)Logging)BedrockStabilityImageEditConfig)AsyncHTTPHandler HTTPHandler_get_httpx_clientget_async_httpx_client) ImageResponse) BaseAWSLLM) BedrockError)AWSPreparedRequestc@s2eZdZUdZded<ded<ded<ded <d S) BedrockImageEditPreparedRequestzP Internal/Helper class for preparing the request for bedrock image edit str endpoint_urlrpreppedbytesbodydictdataN)__name__ __module__ __qualname____doc____annotations__r!r!^/home/app/Keep/.python/lib/python3.10/site-packages/litellm/llms/bedrock/image_edit/handler.pyr&s  rc@s`eZdZdZed.ddZ     d/d0ddZ d1d2d#d$Zd3d%d&Zd4d'd(Z d5d,d-Z dS)6BedrockImageEditz$ Bedrock Image Edit handler model str | NonecCst|rtStd|)Nz*Unsupported model for bedrock image edit: )r Z_is_stability_edit_model ValueError)clsr$r!r!r"get_config_class6s z!BedrockImageEdit.get_config_classFNrimagelistprompt Optional[str]model_responseroptional_paramsr logging_objLitellmLoggingtimeout%Optional[Union[float, httpx.Timeout]] aimage_editboolapi_base extra_headersOptional[dict]client.Optional[Union[HTTPHandler, AsyncHTTPHandler]]api_keyc  Cs|j||||| | || d} |dur*|j| |||||| dur&t| tr&| dSddS| dus3t| ts6t} z| j| j| jj | j d}| Wn&t j ya}z |jj}t||jjdd}~wt jyntdddw|j|||||| jd}|S) N)r$r)r+r.r5r6r/r:T)prepared_requestr1r$r/r+r-r8urlheadersr status_codemessageTimeout error occurred.)r-r$r/r+responser)_prepare_requestasync_image_edit isinstancer r r postrrr>rraise_for_statushttpxHTTPStatusErrorrDr@rtextTimeoutException+_transform_response_dict_to_openai_responser)selfr$r)r+r-r.r/r1r3r5r6r8r:r;rDerr error_coder!r!r" image_edit=sX    zBedrockImageEdit.image_editr;rOptional[AsyncHTTPHandler]returnc s|p ttjjd|id}z|j|j|jj|jdIdH} | Wn&t j y;} z | j j } t| | j jdd} ~ wt jyHtdddw|j|||| |j|d}|S) z= Asynchronous handler for bedrock image edit r1)Z llm_providerparamsr<Nr?rBrC)r$r/r+rDrr-)rlitellmZ LlmProvidersZBEDROCKrHrrr>rrIrJrKrDr@rrLrMrNr) rOr;r1r$r/r+r-r8Z async_clientrDrPrQr!r!r"rF|s0   z!BedrockImageEdit.async_image_editc  Cs|||} ||} |j|| |d} |j|| j| jd\} } | d| d} |j||||d}t| d}ddi}|d urFddi|}|j | j | j|| |||d }|j |d || |j d d t| |||dS)a Prepare the request body, headers, and endpoint URL for the Bedrock Image Edit API Args: model (str): The model to use for the image edit image (list): The images to edit prompt (Optional[str]): The prompt for the edit optional_params (dict): The optional parameters for the image edit api_base (Optional[str]): The base URL for the Bedrock API extra_headers (Optional[dict]): The extra headers to include in the request logging_obj (LitellmLogging): The logging object to use for logging api_key (Optional[str]): The API key to use Returns: BedrockImageEditPreparedRequest: The prepared request object )r$providerr.)r5aws_bedrock_runtime_endpointaws_region_namez/model/z/invoke)r$r)r+r.zutf-8z Content-Typezapplication/jsonN) credentialsrYr6rrr>r:)complete_input_dictr5r>)inputr:additional_args)rrrr)Z*_get_boto_credentials_from_optional_paramsZget_bedrock_invoke_providerZget_bedrock_model_idZget_runtime_endpointrXrY_get_request_bodyjsondumpsencodeZget_request_headersrZZpre_callr>r)rOr$r)r+r.r5r6r/r:Zboto3_credentials_infoZbedrock_providerZmodelId_Zproxy_endpoint_urlrrr>rr!r!r"rEs`     z!BedrockImageEdit._prepare_requestc Cs@|j|d}|}|j|||r|dnd|iid\}}t|S)z Get the request body for the Bedrock Image Edit API Checks the model/provider and transforms the request body accordingly Returns: dict: The request body to use for the Bedrock Image Edit API r$rN)r$r+r)Z"image_edit_optional_request_paramsZlitellm_paramsr>)r(Ztransform_image_edit_requestr) rOr$r)r+r. config_classconfig_instance request_bodyrcr!r!r"r_s  z"BedrockImageEdit._get_request_bodyrDhttpx.Responserc Csl|dur|j|d|jd|idtd|j|}|dur#td|j|d}|} | j|||d}|S) zR Transforms the Image Edit response from Bedrock to OpenAI format Nr[r\)r]r:original_responser^zraw model_response: %sz)Error in response object format, got Nonerd)r$Z raw_responser/)Z post_callrLrdebugr`r&r(Ztransform_image_edit_response) rOr-r$r/r+rDrZ response_dictrerfr!r!r"rNs& zs&