o i @sUdZddlZddlmZmZddlmZmZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZmZmZmZmZmZddlmZddlmZejrZddlZddlZdd l m!Z!dd l mZdd l mZe "d Z#e j$d krej%Z&ejej%fZ'ddlm(Z(n ej)Z&ejfZ'ddl*m(Z(ejrddl+m,Z-ddl.m/Z0n*eZ-ej1e2d<eZ0ej1e2d<zddl+m,Z-ddl.m/Z0Wn e3ydZ-dZ0YnwddddZ4dde45DZ6dede7ej8de9fddZ:ddd e!j;d!ed e!j;d&eejKdejEfd?d@ZMd>ejKdejEfdAdBZNd>ejOdejEfdCdDZPdEeejQdejRfdFdGZSdHeeeBejQejQeBejRfdeBejRfdIdJZTdKeeeeHr$objclsreturncstts t|ds dStfdd|jD}|s?ttjr?z|tfddtjD}W|Sty>YdSw|S)aChecks if an object has all of the fields of a Pydantic model. This is a duck-typing alternative to `isinstance` to solve dual-import problems. It returns False for dictionaries, which should be handled by `isinstance(obj, dict)`. Args: obj: The object to check. cls: The Pydantic model class to duck-type against. Returns: True if the object has all the fields defined in the Pydantic model, False otherwise. model_fieldsFc3|]}t|VqdSNhasattr)r field)r&rr# ^z#_is_duck_type_of..c3r*r+r,)r f) obj_privaterr#r/dr0) isinstancedictr-allr)pydantic BaseModeltype ValueError)r&r' all_matchedr)r&r2r#_is_duck_type_ofKs r;)collection_hierarchy_depthclient resource_namecollection_identifierr=cCs||d o|d|dd|k}|jrX|dr!|S|dr/d|jd|S||drDd|jd|jd|S|rVd|jd|jd|d|S|S|ra|d|S|S)a|Prepends resource name with project, location, collection_identifier if needed. The collection_identifier will only be prepended if it's not present and the prepending won't violate the collection hierarchy depth. When the prepending condition doesn't meet, returns the input resource_name. Args: client: The API client. resource_name: The user input resource name to be completed. collection_identifier: The collection identifier to be prepended. See collection identifiers in https://google.aip.dev/122. collection_hierarchy_depth: The collection hierarchy depth. Only set this field when the resource has nested collections. For example, `users/vhugo1802/events/birthday-dinner-226`, the collection_identifier is `users` and collection_hierarchy_depth is 4. See nested collections in https://google.aip.dev/122. Example: resource_name = 'cachedContents/123' client.vertexai = True client.project = 'bar' client.location = 'us-west1' _resource_name(client, 'cachedContents/123', collection_identifier='cachedContents') returns: 'projects/bar/locations/us-west1/cachedContents/123' Example: resource_name = 'projects/foo/locations/us-central1/cachedContents/123' # resource_name = 'locations/us-central1/cachedContents/123' client.vertexai = True client.project = 'bar' client.location = 'us-west1' _resource_name(client, resource_name, collection_identifier='cachedContents') returns: 'projects/foo/locations/us-central1/cachedContents/123' Example: resource_name = '123' # resource_name = 'cachedContents/123' client.vertexai = False _resource_name(client, resource_name, collection_identifier='cachedContents') returns 'cachedContents/123' Example: resource_name = 'some/wrong/cachedContents/resource/name/123' resource_prefix = 'cachedContents' client.vertexai = False # client.vertexai = True _resource_name(client, resource_name, collection_identifier='cachedContents') returns: 'some/wrong/cachedContents/resource/name/123' Returns: The completed resource name. /r projects/z locations/ /locations/) startswithcountvertexaiprojectlocation)r>r?r@r=$should_prepend_collection_identifierrrr#_resource_namejs$E   rJmodelcCs|stdd|vsd|vsd|vrtd|jrC|ds(|ds(|dr*|Sd |vr>|d d \}}d|d |Sd |S|drJ|S|d rQ|Sd|S)Nzmodel is required.z..?&zinvalid model parameter.rBmodels/ publishers/rAr z/models/zpublishers/google/models/z tunedModels/)r9rFrDsplit)r>rK publishermodel_idrrr#t_models*    rS api_client base_modelscCs|jr |rdSdS|r dSdS)Nzpublishers/google/modelsmodels tunedModels)rF)rTrUrrr# t_models_urlsrXresponsecCs|sgS|d}|dur|S|d}|dur|S|d}|dur%|S|ddur5|ddur5gStdtd|gS)NrVrWpublisherModels httpHeaders jsonPayloadz!Cannot determine the models type.z1Cannot determine the models type for response: %s)getloggerwarningdebug)rYrV tuned_modelspublisher_modelsrrr#t_extract_modelss&    rccCsjt||}|s dS|dr|jrd|jd|jd|S|dr3|jr3d|jd|jd|S|S)NrOrBrCrArNz/publishers/google/)rSrDrFrGrH)rTrKrrr#t_caches_models rdimgcCsz ddl}|j}Wn tyd}Ynwt}|dur#t||js(|jdkr2|j|ddd}n |j|ddd}| d| }t j ||dS) NrRGBAPNG)formatz image/pngJPEGz image/jpeg) mime_typedata) PIL.PngImagePluginPngImagePlugin ImportErrorioBytesIOr3 PngImageFilemodesaveseekreadrBlob)rePILrmbytesiorjrkrrr# pil_to_blob s$     ryfunction_responsecCsD|stdt|trtj|St|tjr|Stdt|)Nzfunction_response is required.zOCould not parse input as FunctionResponse. Unsupported function_response type: ) r9r3r4rFunctionResponsemodel_validater; TypeErrorr8)rzrrr#t_function_response9s   r~function_responsescCs.|stdt|trdd|DSt|gS)Nz function_responses are required.cSg|]}t|qSr)r~)r rYrrr# Rz(t_function_responses..)r9r3r r~rrrr#t_function_responsesIs   rblobscC"t|tr dd|DSt|gS)NcSrr)t_blob)r blobrrr#r[rzt_blobs..)r3listr)rrrr#t_blobsW  rrcCs|stdt|tjr|St|trtj|Sd|jj vrDz ddl }|j j }Wn t y6d}Ynw|durDt||rDt |Stdt|)Nzblob is required.imagerz6Could not parse input as Blob. Unsupported blob type: )r9r;rrvr3r4r| __class____name__lower PIL.ImageImagernryr}r8)rrw PIL_Imagerrr#r`s$      rcC.t|}|jr|jdr|Std|j)Nzimage/Unsupported mime type: rrjrDr9rrrr# t_image_blobzrcCr)Nzaudio/rrrrrr# t_audio_blobrrpartcCs|durtdt|trtj|dSt|tjr-|jr|js#tdtjj |j|jdSt|t rNztj |WSt j yMtjtj |dYSwt|tjrV|Sd|jjvrz ddl}|jj}Wn tysd}Ynw|durt||rtjt|dStd t|) Nzcontent part is required.)textz$file uri and mime_type are required.)file_urirj) file_datarr) inline_datazUnsupported content part type: )r9r3strrPartr;Fileurirjfrom_urir4r|r6ValidationErrorFileDatarrrrrrnryr8rrwrrrr#t_parts4        rpartscCs@|dus t|tr|stdt|trdd|DSt|gS)Nzcontent parts are required.cSrr)rr rrrr#rrzt_parts..)r3rr9rrrrr#t_partss   r predictionscCsP|sdSg}|D]}|dr%|tjtj|dd|ddddq|S)NrgcsUri imageBytes)gcs_uri image_bytes)r)r]appendrGeneratedImager)rimages predictionrrr#t_image_predictionss   rcontentcCs|durtdt|tjr|St|tr>ztj|WStjy=t |}|j r4tj |gdYStj |gdYSwt|tj rMtj t |gdSt|tjrd|j r]tj |gdStj |gdStj |dS)Nzcontent is required.r)r9r;rContentr3r4r|r6rr function_call ModelContent UserContentrr)r possible_partrrr# t_contents0       rcontentscCst|tr dd|D}nt|g}|jrGg}|D]+}|durDt|tr*tj|}|jdurD|jD]}|j r>| |j q2t dq2q|S|S)NcSrr)rr rrrr#rrz(t_contents_for_embed..z/Non-text part found, only returning text parts.) r3rrrFr4rrr|rrrr^r_)r>rtransformed_contents text_partsrrrrr#t_contents_for_embeds"       rcs|dus t|tr|stdt|tst|gSg}g}dttjtfdttjfdd}dtj dt fdddttj dt ffd d d ttj d ttj ddffd d d ttj d ttj dtjddffdd }|D]I}t |tj st|tr||t|tr| tj|dqs| |qs||r||||qst|tr| tj |qstdt||||S)Nzcontents are required.rr(c Sst|tst|tjst|tjrdSt|trE|sdSz tj|WdStj yDz tj |WYdStj yCYYdSwwd|j j vrnz ddl}|jj}Wn tybd}Ynw|durnt||rndSdS)NTFrr)r3rr;rrrr4r|r6rrrrrrrrnrrrr#_is_part s>       zt_contents.._is_partcSs|j Sr+)r)rrrr# _is_user_part2sz!t_contents.._is_user_partrcstfdd|DS)Nc3s|]}|VqdSr+rrrrr#r/6sz6t_contents.._are_user_parts..)r5rrrr#_are_user_parts5sz#t_contents.._are_user_partsresultaccumulated_partscs>|sdS||rtj|dntj|dg|dd<dS)Nr)rrrr)rr)rrr#$_append_accumulated_parts_as_content8s z8t_contents.._append_accumulated_parts_as_content current_partcsBt|}||kr||dS|||g|dd<dSr+)rr)rrrrrrrr#_handle_current_partEs  z(t_contents.._handle_current_partrzUnsupported content type: )r3rr9rr r PartUnionDictrrrboolrr;rrr4r|r8)rrrrrrrrr# t_contentssT    %      rschemacCs|dddkrd|d<|d=dSd|vrO|dD]7}d|vrN|ddkrNd|d<|dddit|ddkrN|ddD]\}}|||<qB|d=qdSdS) aProcess null fields in the schema so it is compatible with OpenAPI. The OpenAPI spec does not support 'type: 'null' in the schema. This function handles this case by adding 'nullable: True' to the null field and removing the {'type': 'null'} entry. https://swagger.io/docs/specification/v3_0/data-models/data-types/#null Example of schema properties before and after handling null fields: Before: { "name": { "title": "Name", "type": "string" }, "total_area_sq_mi": { "anyOf": [ { "type": "integer" }, { "type": "null" } ], "default": None, "title": "Total Area Sq Mi" } } After: { "name": { "title": "Name", "type": "string" }, "total_area_sq_mi": { "type": "integer", "nullable": true, "default": None, "title": "Total Area Sq Mi" } } r8NnullTnullableanyOfr r)r]removelenitems)ritemkeyvalrrr#handle_null_fieldsls,   rorigincCstd|)z2Raises an error if the schema type is unsupported.Unsupported schema type: )r9rrrr#"_raise_for_unsupported_schema_typesrcCs2|r|js|ds|drtddSdSdS)NadditionalPropertiesadditional_propertiesz8additionalProperties is not supported in the Gemini API.)rFr]r9)rr>rrr#'_raise_for_unsupported_mldev_propertiess rTorder_propertiesdefsrcsX|ddkr |d=t|dD]\}}||d}dur#|||<qdur?|diD] \}}t|dq2t||dd} durY|| dd d tj d tj ffd d |d} dur~fdd| D|d<dS|d} t | t r| j } t | t r| } |d} | dur| dkr| g|d<|d=ntd| dkr|d} durt| D] \}}|| |<qt| dkrrd|vrt| |d<|d}durt |tr||d<dSdSdS| dkr(|d}dur||d<|d}dur*fdd|D|d<dSdSdS) a{Updates the schema and each sub-schema inplace to be API-compatible. - Inlines the $defs. Example of a schema before and after (with mldev): Before: `schema` { 'items': { '$ref': '#/$defs/CountryInfo' }, 'title': 'Placeholder', 'type': 'array' } `defs` { 'CountryInfo': { 'properties': { 'continent': { 'title': 'Continent', 'type': 'string' }, 'gdp': { 'title': 'Gdp', 'type': 'integer'} }, } 'required':['continent', 'gdp'], 'title': 'CountryInfo', 'type': 'object' } } After: `schema` { 'items': { 'properties': { 'continent': { 'title': 'Continent', 'type': 'string' }, 'gdp': { 'title': 'Gdp', 'type': 'integer' }, } 'required':['continent', 'gdp'], 'title': 'CountryInfo', 'type': 'object' }, 'type': 'array' } titlePlaceholderLiteralEnum))rr)any_ofr) prefix_items prefixItems)property_orderingpropertyOrderingNz$defsr$refdefs/ sub_schemar(cs:|dd}dur|dd}t|d|S)z@Returns the processed `sub_schema`, resolving its '$ref' if any.rNrrr)poprPprocess_schema)rref)r>rrrr#_recurse sz process_schema.._recursercg|]}|qSrr)r rrrr#r(rz"process_schema..r8constSTRINGenumzLiteral values must be strings.OBJECT propertiesr rrrARRAYrrcrrr)r prefixrrr#rNr)r]rrrrrupdaterPr StringDictr3rvaluerupperr9rrkeysr4)rr>rr from_nameto_namer_rrr schema_typerrname additionalrprefixesr)rr>rrr#rshC           rrcsd}|D]}t|jtrd}qt|jts#td|jdt|jq||r9dd|D}t|j|td}|Gfdd d t j }| }t |||d d }t j|S) NFTz Enum member z( value must be a string or integer, got cSsg|]}t|jqSr)rr)r memberrrr#rar%z!_process_enum..)r8ceZdZUed<dS)z"_process_enum..Placeholder placeholderNr __module__ __qualname____annotations__renum_to_processrr# Placeholdere rrr )r3rintrr}rr8rrr6r7model_json_schemarrSchemar|)rr>is_integer_enumr str_membersstr_enumr enum_schemarrr# _process_enumQs*      rcCst|to tdd|DS)zEVerifies the schema is of type dict[str, Any] for mypy type checking.css|]}t|tVqdSr+)r3r)r rrrr#r/rs  z(_is_type_dict_str_any..)r3r4r5rrrr#_is_type_dict_str_anynsrcsFsdSttrtrt|tjSttr"t|St tjrGtttkr6t j dd}t||tj|Stt sftt rfttjrf}t||tj|Stt s|tt s|tts|ttvrGfdddtj}|}t|||dd}tj|Std)NT) exclude_unsetcr )zt_schema..Placeholderr Nr rrrr#rrrrr r)r3r4rrrrr|rrr;r model_dumprr8 issubclassr6r7rVersionedUnionTypetyping get_origin _UNION_TYPESr9)r>rrrrrr#t_schemawsF              r#cCsf|sdSt|tjr |St|trtjtjtj|dddSt|tr*tj|St dt |)N) voice_name)prebuilt_voice_config) voice_configzUnsupported speechConfig type: ) r;r SpeechConfigr3r VoiceConfigPrebuiltVoiceConfigr4r|r9r8rrrr#t_speech_configs     r*cCs<t|tjr|}t|trtj|}|jdurtd|S)Nzcallablefunction_declarations) inspect isfunctionismethodrrFunctionDeclaration from_callablerr;r r3r4r|)r>rrrr#t_tools  r6cCst|sgStjgd}g}|D]!}t||}|dur/|jr*|jdur*|j|j7_q||q|jr8|||S)Nr/)rrr6r0r)r>r function_tooltoolstooltransformed_toolrrr#t_toolss$     r;rcCst||ddS)NcachedContents)r@)rJ)r>rrrr#t_cached_content_namesr=srccCst|tr tjdi|}t|tjrFt|jdu|jdug}t|jdu|j dug}|j r:|s4|dkr8t d|S|s@|dkrDt d|St|t rQtj|dSt|t rz|drctjd|gdS|drotjd |d S|d rztj|d St d |)Nr zeExactly one of `gcs_uri` or `bigquery_uri` must be set, other sources are not supported in Vertex AI.Exactly one of `inlined_requests`, `file_name`, `inlined_embed_content_requests`, or `embed_content_file_name` must be set, other sources are not supported in Gemini API.)inlined_requestsgs://jsonlrhrbq://bigqueryrh bigquery_urifiles/) file_namezUnsupported source: r)r3r4rBatchJobSourcer;sumrrGr@rIrFr9rrrD)r>r>vertex_sources mldev_sourcesrrr#t_batch_job_sourcesN          rNcCsdt|tr tjdi|}t|tjr)t|jdu|jdug}|dkr'td|Stdt |)Nr r?zUnsupported source type: r) r3r4rEmbeddingsBatchJobSourcer;rKr@rIr9r8)r>r>rMrrr#t_embedding_batch_job_source.s  rPdestcCst|trtjdi|}|St|tr3|dr tjd|dS|dr,tjd|dStd|t|tjr;|Std|) NrArBrCrDrErFzUnsupported destination: r)r3r4rBatchJobDestinationrrDr9r;)rQrrr#t_batch_job_destinationEs$     rScCsX|didg}|s|S|D]}|di}|sqd|vr)|d|d<|Sq|S)NinlinedResponsesrY embeddinginlinedEmbedContentResponses)r]r)rQinline_responsesrYinner_responserrr#t_recv_batch_job_destination^s  rYcCsn|jsd}t||r|ddStd|dd}t||r)|ddS|r/|Std|d)Nzbatches/[^/]+$rArzInvalid batch job name: .z:^projects/[^/]+/locations/[^/]+/batchPredictionJobs/[^/]+$)rFrematchrPr9isdigit)r>r mldev_patternvertex_patternrrr#t_batch_job_nameos  r`statecCsX|dkrdS|dkr dS|dkrdS|dkrdS|d krd S|d kr$d S|d kr*dS|S)NBATCH_STATE_UNSPECIFIEDJOB_STATE_UNSPECIFIEDBATCH_STATE_PENDINGJOB_STATE_PENDINGBATCH_STATE_RUNNINGJOB_STATE_RUNNINGBATCH_STATE_SUCCEEDEDJOB_STATE_SUCCEEDEDBATCH_STATE_FAILEDJOB_STATE_FAILEDBATCH_STATE_CANCELLEDJOB_STATE_CANCELLEDBATCH_STATE_EXPIREDJOB_STATE_EXPIREDr)rarrr# t_job_statesrpg?g4@g @g?structcCs|d}r^d|vr^|}d}t}|ddkrE|tkr&td|d||jd|id }t|||7}t|tt }|ddks|d }rYtd|d |d ||d S|S)Nrz /operations/gdoneTz Operation z timed out. GET) http_methodpath request_dicterrorz failed with error: z. rY) r]!LRO_POLLING_INITIAL_DELAY_SECONDSLRO_POLLING_TIMEOUT_SECONDS RuntimeErrorrequesttimesleepminLRO_POLLING_MULTIPLIER!LRO_POLLING_MAXIMUM_DELAY_SECONDS)rTrqr operation total_seconds delay_secondsrwrrr#t_resolve_operations.  rcCst|tjr |j}nt|tjr|j}nt|tjr&|jdur$|jj}nd}|dur.tdt |t s=tdt |d| dra| dd}td|}|durZtd||d }|S| drm| dd}|S) NzFile name is required.z"Could not convert object of type `z` to a file name.zhttps://rHr z [a-z0-9]+z&Could not extract file name from URI: r)r;rrrVideorGeneratedVideovideor9r3rr8rDrPr[r\group)rsuffixr\rrr# t_file_names0          rstatuscCsf|dkrtjjS|dkrtjjS|dkrtjjS|dkr tjjStjD] }t|j|kr0|Sq#|S)NSTATE_UNSPECIFIEDCREATINGACTIVEFAILED)rJobStatercrgrirkrr)rrarrr#t_tuning_job_statuss rcCs:t|tr tj|St|tjr|Stdt|d)NCould not convert input (type "z") to `types.Content`)r3r4rrr|r;r9r8)rrrr#t_content_stricts   rcCr)NcSrr)rrrrr#rrz%t_contents_strict..)r3r rrrrr#t_contents_strictrrturns turn_completec CsZ|dur tj|dSz tjt|d|dWSty,}z tdt|d|d}~ww)N)rr)rrrz") to `types.LiveClientContent`)rLiveClientContentr Exceptionr9r8)rrerrr#t_client_contents rinputc CsV|s td|z tjt|ddWSty*}z tdt|d|d}~ww)Nz#A tool response is required, got: rrz$") to `types.LiveClientToolResponse`)r9rLiveClientToolResponserrr8)rrrrr#t_tool_responsesrmetricsc Csg}|D]n}i}ddg|d<t|dg}|dkri|d<nN|dkr(i|d<nE|d r:|d d }d |i|d <n3t|drf|jrfd|ji}t|dg}|rS||d<t|dg}|rad|i|d<||d<ntd|||q|S)a Prepares the metric payload for the evaluation request. Args: request_dict: The dictionary containing the request details. resolved_metrics: A list of resolved metric objects. Returns: The updated request dictionary with the prepared metric payload. AVERAGESTANDARD_DEVIATIONaggregation_metricsrrexact_match_specr bleu_specrouger rouge_typerprompt_templatemetric_prompt_templatejudge_model_system_instructionsystem_instructionreturn_raw_outputcustom_output_format_configpointwise_metric_specz0Unsupported metric type or invalid metric name: )getvrrDreplacer-rr9r) rmetrics_payloadmetricmetric_payload_item metric_namerpointwise_specrrrrr# t_metrics'sB        rr+)NT)__doc__base64collections.abcrrrrrr1rologgingr[sysr|r builtin_typesr rrrr r r _mcp_utilsr rrr TYPE_CHECKINGrrwr6rr getLoggerr^ version_info UnionTyperr"r_UnionGenericAliastyping_extensionsmcprr mcp.typesrrTyperrnmetric_name_sdk_api_maprmetric_name_api_sdk_mapr8r7rr; BaseApiClientrrrJrSrXrrrcrdrvryFunctionResponseOrDictr{r~rBlobImageUnionDictrrr BlobOrDictrrrrrrrr ContentDict ContentTyperrContentListUnionContentListUnionDictrrrrrrrSchemaUnionDictrr#SpeechConfigUnionDictr'r*SpeechConfigOrDictr-r6r;r=BatchJobSourceUnionDictrJrNEmbeddingsBatchJobSourceOrDictrOrPBatchJobDestinationOrDictrRrSr4rYr`rprxrryrrrrrrrr ContentOrDictrrrrrrMetricSubclassrrrrr#s"             $ ]             l;        0      2   "  "