[Th ddlZddlZddlmZmZmZddlmZddlm Z ddlm Z ddlm Z ddlm Z dd lmZdd lmZdd l mZdd l mZdd lmZmZej0dZ dgdeeeefefdeeeefdeeeffdZ dgdeeeefefdeeeefdeeeffdZ dgdeeeefefdeeeefdeeeffdZ dgdeeeefefdeeeefdeeeffdZ dgdeeeefefdeeeefdeeeffdZ! dgdeeeefefdeeeefdeeeffdZ" dgdeeeefefdeeeefdeeeffdZ# dgdeeeefefdeeeefdeeeffdZ$ dgdeeeefefdeeeefdeeeffdZ% dgdeeeefefdeeeefdeeeffdZ& dgdeeeefefdeeeefdeeeffdZ' dgdeeeefefdeeeefdeeeffdZ( dgdeeeefefdeeeefdeeeffdZ) dgdeeeefefdeeeefdeeeffdZ* dgdeeeefefdeeeefdeeeffd Z+ dgdeeeefefdeeeefdeeeffd!Z, dgdeeeefefdeeeefdeeeffd"Z- dgdeeeefefdeeeefdeeeffd#Z. dgdeeeefefdeeeefdeeeffd$Z/ dgdeeeefefdeeeefdeeeffd%Z0 dgdeeeefefdeeeefdeeeffd&Z1 dgdeeeefefdeeeefdeeeffd'Z2 dgdeeeefefdeeeefdeeeffd(Z3 dgdeeeefefdeeeefdeeeffd)Z4 dgdeeeefefdeeeefdeeeffd*Z5 dgdeeeefefdeeeefdeeeffd+Z6 dgd,edeeeefefdeeeefdeeeffd-Z7 dgd,edeeeefefdeeeefdeeeffd.Z8 dgd,edeeeefefdeeeefdeeeffd/Z9 dgdeeeefefdeeeefdeeeffd0Z: dgd,edeeeefefdeeeefdeeeffd1Z; dgdeeeefefdeeeefdeeeffd2Z< dgd,edeeeefefdeeeefdeeeffd3Z= dgd,edeeeefefdeeeefdeeeffd4Z> dgdeeeefefdeeeefdeeeffd5Z? dgd,edeeeefefdeeeefdeeeffd6Z@ dgd,edeeeefefdeeeefdeeeffd7ZA dgd,edeeeefefdeeeefdeeeffd8ZB dgdeeeefefdeeeefdeeeffd9ZC dgdeeeefefdeeeefdeeeffd:ZD dgd,edeeeefefdeeeefdeeeffd;ZE dgdeeeefefdeeeefdeeeffd<ZF dgdeeeefefdeeeefdeeeffd=ZG dgdeeeefefdeeeefdeeeffd>ZH dgd,edeeeefefdeeeefdeeeffd?ZI dgd,edeeeefefdeeeefdeeeffd@ZJ dgd,edeeeefefdeeeefdeeeffdAZK dgdeeeefefdeeeefdeeeffdBZL dgdeeeefefdeeeefdeeeffdCZM dgd,edeeeefefdeeeefdeeeffdDZN dgdeeeefefdeeeefdeeeffdEZO dgdeeeefefdeeeefdeeeffdFZP dgdeeeefefdeeeefdeeeffdGZQ dgdeeeefefdeeeefdeeeffdHZR dgdeeeefefdeeeefdeeeffdIZS dgdeeeefefdeeeefdeeeffdJZT dgdeeeefefdeeeefdeeeffdKZU dgdeeeefefdeeeefdeeeffdLZV dgdeeeefefdeeeefdeeeffdMZW dgdeeeefefdeeeefdeeeffdNZX dgdeeeefefdeeeefdeeeffdOZY dgdeeeefefdeeeefdeeeffdPZZ dgdeeeefefdeeeefdeeeffdQZ[ dgdeeeefefdeeeefdeeeffdRZ\ dgdeeeefefdeeeefdeeeffdSZ] dgdeeeefefdeeeefdeeeffdTZ^ dgdeeeefefdeeeefdeeeffdUZ_ dgdeeeefefdeeeefdeeeffdVZ` dgdeeeefefdeeeefdeeeffdWZa dgdeeeefefdeeeefdeeeffdXZb dgdeeeefefdeeeefdeeeffdYZc dgdeeeefefdeeeefdeeeffdZZd dgdeeeefefdeeeefdeeeffd[Ze dgdeeeefefdeeeefdeeeffd\Zf dgdeeeefefdeeeefdeeeffd]Zg dgdeeeefefdeeeefdeeeffd^ZhGd_d`e jZjGdadbe jZkdceddejdemeeeefffdeZndceddejdemeeeefffdfZpy)hN)AnyOptionalUnion) urlencode) _api_module)_common) _extra_utils) _transformers)types) BaseApiClient)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.batches from_object parent_objectreturnci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|S)Nfps end_offset endOffset start_offset startOffsetgetvsetvrr to_objects Y/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/google/genai/batches.py_VideoMetadata_to_mldevr!%s!) +w+UGT+w78 + ~&2[M4 l^#DE +'(4]OT+7G%HI ci}t|dg tdt|dgt|dgt|dgt|dgt|dgt|dg|S)N display_name6display_name parameter is not supported in Gemini API.data mime_typemimeTyper ValueErrorrrs r _Blob_to_mldevr+6sw!) +'(4 M NN +x ,VHd;9: + }%1ZL${[M"BC r"ci}t|dg tdt|dgt|dgt|dgt|dgt|dgt|dg|S)Nr$r%file_urifileUrir'r(r)rs r _FileData_to_mldevr/Gsw!) +'(4 M NN + |$0YKkJ +y!-WItK';< + }%1ZL${[M"BC + ~&2[M4 l^#DE +()*6_%tK:J9K'LM + {#/YKkI;!?@ + }%1ZL${[M"BC + ~&2[M4 l^#DE +()*6_%tK:J9K'LM + {#/YKkI;!?@ + |$0ZL${ZL"AB + {#/YKkI;!?@ + ~&2\ND|n$EF ++,-9  [./0  + |$0ZL${ZL"AB +y!-WItK';< +x ,VHd;9: r"ci}t|dg tdt|dgt|dgt|dgt|dgt|dgt|dg|S)Nmethodz0method parameter is not supported in Gemini API.category thresholdr)rs r _SafetySetting_to_mldevrzsv!) +z". G HH + |$0ZL${ZL"AB + }%1[M4 k]#CD r"ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dg|S) NbehaviorrZr4 parametersparameters_json_schemaparametersJsonSchemaresponseresponse_json_schemaresponseJsonSchemarrs r _FunctionDeclaration_to_mldevr,s1!) + |$0ZL${ZL"AB + '3]OT+ %GH +x ,VHd;9: + ~&2\ND|n$EF +012>   [345  + |$0ZL${ZL"AB +./0<  [123 r"ci}t|dgt|dgt|dgt|dgt|dgt|dg|S)N start_time startTimeend_timeendTimerrs r _Interval_to_mldevrQs[!) + ~&2[M4 l^#DE + |$0YKkJ   [345 r"ci}t|dgt|dgt|dgt|dgt|dgt|dg|S)Nlatitude longituderrs r _LatLng_to_mldevrs[!) + |$0ZL${ZL"AB + }%1[M4 k]#CD r"c i}t|dg#t|dgtt|dg|t|dgt|dgt|dg|S)Nlat_lnglatLng language_code languageCode)rrrrs r _RetrievalConfig_to_mldevr sl!) + {#/  kI;7C  +()5^$d;8I&JK r"c i}t|dg#t|dgtt|dg|t|dg#t|dgtt|dg||S)Nfunction_calling_configfunctionCallingConfigretrieval_configretrievalConfig)rrrrrs r _ToolConfig_to_mldevrs!) +123? !' 89 :I  +*+,8 ! 12 3Y  r"cVi}t|dgt|dgt|dg|S)N voice_name voiceNamerrs r _PrebuiltVoiceConfig_to_mldevr6s5!) + ~&2[M4 l^#DE r"c ji}t|dg#t|dgtt|dg||S)Nprebuilt_voice_configprebuiltVoiceConfig)rrrrs r _VoiceConfig_to_mldevrAsK!) +/01= % 67 8)  r"c i}t|dgt|dgt|dgt|dg#t|dgtt|dg||S)Nspeaker voice_config voiceConfig)rrrrs r _SpeakerVoiceConfig_to_mldevrRsk!) + {#/YKkI;!?@ +'(4 d;0@A9M r"c i}t|dg1t|dgt|dgDcgc]}t||c}|Scc}w)Nspeaker_voice_configsspeakerVoiceConfigs)rrrrOs r !_MultiSpeakerVoiceConfig_to_mldevrdsb!) +/01= [+B*CD  )y 9    A c i}t|dg#t|dgtt|dg|t|dg#t|dgtt|dg|t|dgt|dgt|dg|S)Nrrmulti_speaker_voice_configmultiSpeakerVoiceConfigrr)rrrrrs r _SpeechConfig_to_mldevrvs!) +'(4 d;0@A9M  +456B "#) ;< =y  +()5^$d;8I&JK r"ci}t|dgt|dgt|dgt|dgt|dgt|dg|S)Ninclude_thoughtsincludeThoughtsthinking_budgetthinkingBudgetrrs r _ThinkingConfig_to_mldevrsl!) +*+,8%&[;M:N(O +)*+7%&[;L:M(NO r" api_clientc b i}t|dg6t|dgttjt|dg|t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d gt|d gt|d gt|d gt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg7t|dgt tj |t|dg|t|dgt|dgt|dgt|dg tdt|dg tdt|d g1t|d!gt|d gDcgc]}t||c}t|d"gYt|d"gtj|t|d"gDcgc]"}ttj|||$c}t|d#g#t|d$gtt|d#g|t|d%g td&t|d'g-t|d(gtj|t|d'gt|d)gt|d*gt|d)gt|d+gt|d,gt|d+gt|d-g6t|d.gttjt|d-g|t|d/g td0t|d1g#t|d2gt!t|d1g||Scc}wcc}w)3Nsystem_instructionsystemInstruction temperaturetop_ptopPtop_ktopKcandidate_countcandidateCountmax_output_tokensmaxOutputTokensstop_sequences stopSequencesresponse_logprobsresponseLogprobslogprobspresence_penaltypresencePenaltyfrequency_penaltyfrequencyPenaltyseedresponse_mime_typeresponseMimeTyperesponse_schemaresponseSchemarrrouting_configz8routing_config parameter is not supported in Gemini API.model_selection_configz@model_selection_config parameter is not supported in Gemini API.safety_settingssafetySettingstools tool_config toolConfiglabelsz0labels parameter is not supported in Gemini API.cached_content cachedContentresponse_modalitiesresponseModalitiesmedia_resolutionmediaResolution speech_config speechConfigaudio_timestampz9audio_timestamp parameter is not supported in Gemini API.thinking_configthinkingConfig)rrrQt t_contentrut_schemar*rzt_toolsrt_toolrt_cached_content_namert_speech_configrrrrrrPs r _GenerateContentConfig_to_mldevrsk !) +,-.:  KK[+?*@A BI  + '3]OT+ %GH +y!-VHd; :; +y!-VHd; :; +)*+7%&[;L:M(NO ++,-9%&[;N:O(P +()*6_%tK:J9K'LM ++,-9  [./0  + |$0ZL${ZL"AB +*+,8%&[;M:N(O ++,-9  [./0  +x ,VHd;9: +,-.:  [/01  +)*+7  JJz4 6G5H#I J   +./0<  [123  +()*6 O PP +012> J  +)*+7 [+<*=>  $D) 4  +y!-   *d; .JK  188J5y A  + '3 T+ ?K  +z". G HH +()*6   [+;*<=  +-./;  [012  +*+,8%&[;M:N(O +()5   d;0AB CY  +)*+7 C  +)*+7  01 2I  M  s R' 'R, c i}t|dg.t|ddgtj|t|dgt|dgEt|ddgtjt|dgDcgc]}t ||c}t|dg%t|ddgt |t|dg||Scc}w)NmodelrequestcontentsconfiggenerationConfig)rrrt_model t_contentsrQrrs r _InlinedRequest_to_mldevrKs !) +y!- G *d; :;  + |$0 J T+ |%DE  dI .  +z". &'' [8*5y   s6C c pi}t|dg tdt|dg tdt|dg tdt|dgt|dgt|dgt|d g3t|d d gt|d gDcgc]}t|||c}|Scc}w) Nr]z0format parameter is not supported in Gemini API.gcs_uriz1gcs_uri parameter is not supported in Gemini API. bigquery_uriz6bigquery_uri parameter is not supported in Gemini API. file_namefileNameinlined_requestsrequests)rr*rrrs r _BatchJobSource_to_mldevr'ns !) +z". G HH + {#/ H II +'(4 M NN + }%1ZL${[M"BC +*+,8 Z [+=*>?  %Zy A    sB3 ci}t|dgt|ddgt|dgt|dg td|S)Nr$batch displayNamedestz.dest parameter is not supported in Gemini API.rrr*rs r _CreateBatchJobConfig_to_mldevr-s\!) +'(4 -  [>*+  +x , E FF r"cli}t|dg.t|ddgtj|t|dgt|dg9t|ddgt |tj |t|dg|t|dg#t|dgt t|dg||SNr_urlsrcr) inputConfigr)rrrrr't_batch_job_sourcer-rrrrs r "_CreateBatchJobParameters_to_mldevr5s !) +y!-  *d; :;  +w+ -   T+w-G H   +z".  & xj )9  r"cTi}t|dgt|ddgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|dg tdt|d g td |S) N task_type requests[]taskTypersoutput_dimensionalityoutputDimensionalityr'z3mime_type parameter is not supported in Gemini API. auto_truncatez7auto_truncate parameter is not supported in Gemini API.r,rs r _EmbedContentConfig_to_mldevr=s!) + }%1 z" [;-(  +y!-w/kG91MN +/01= -. [234  + }%1 J KK +()5 N OO r"c i}t|dg.t|gdtj|t|dgt|dg#t|dgt t|dg||S)Nr)r8rcontentr)rrrt_contents_for_embedr=r4s r _EmbedContentBatch_to_mldevrAs{ !) + |$0, z4 j\+JK  +z".  $T+z%BIN r"c i}t|dgt|dgt|dgt|dg$t|dgt|t|dg||S)Nr#r%r&)rrrAr4s r "_EmbeddingsBatchJobSource_to_mldevrCsr !) + }%1[M4 k]#CD +*+,8  # [+=*>?  r"cXi}t|dgt|ddgt|dg|S)Nr$r)r*rrs r (_CreateEmbeddingsBatchJobConfig_to_mldevrEsA!) +'(4 -  [>*+ r"c Di}t|dg.t|ddgtj|t|dgt|dg%t|ddgt |t|dg|t|dg#t|dgt t|dg||Sr/)rrrrrCrEr4s r ,_CreateEmbeddingsBatchJobParameters_to_mldevrG s !) +y!-  *d; :;  +w+ - * [5'2I  +z".  0 xj )9  r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SNr4r0rrrrt_batch_job_namer4s r _GetBatchJobParameters_to_mldevrLBr !) +x ,  :tK&'BC  +z".XJ[8* => r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrIrJr4s r "_CancelBatchJobParameters_to_mldevrOUrMr"ci}t|dgt|ddgt|dgt|dgt|ddgt|dgt|dg td|S)N page_size_querypageSize page_token pageTokenfilterz0filter parameter is not supported in Gemini API.r,rs r _ListBatchJobsConfig_to_mldevrWhs!) + }%1*-tK+/O + ~&2 ; [<.)  +z". G HH r"c ji}t|dg#t|dgtt|dg||SNr)rrrWrs r !_ListBatchJobsParameters_to_mldevrZsC!) +z".  %d; &CYO r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrIrJr4s r "_DeleteBatchJobParameters_to_mldevr\rMr"cRi}t|dgt|dgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|d g td t|d g td |S) Nr]instancesFormatr! gcsSourceurisr"bigquerySourceinputUrir#2file_name parameter is not supported in Vertex AI.r%z9inlined_requests parameter is not supported in Vertex AI.r,rs r _BatchJobSource_to_vertexrds!) +z".&'kH:)FG + {#/[&)4 i[+IJ +'(4 :& [>*+  + }%1 I JJ +*+,8 C  r"ci}t|dgt|dgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|d g td t|d g td t|d g td|S)Nr]predictionsFormatr!gcsDestinationoutputUriPrefixr"bigqueryDestination outputUrir#rcinlined_responsesz:inlined_responses parameter is not supported in Vertex AI.inlined_embed_content_responseszHinlined_embed_content_responses parameter is not supported in Vertex AI.r,rs r _BatchJobDestination_to_vertexrms!) +z".()4 hZ+HI + {#/ ,- [9+&  +'(4  , [>*+  + }%1 I JJ ++,-9 D  +9:;G    r"c i}t|dgt|dgt|dgt|dg6t|dgttjt|dg||S)Nr$r*r+ outputConfig)rrrmrt_batch_job_destinationrs r _CreateBatchJobConfig_to_vertexrqsz!) +'(4kN;K)LM +x , & % %d;&A BI  r"c fi}t|dg-t|dgtj|t|dgt|dg7t|dgt tj |t|dg|t|dg#t|dgt t|dg||S)Nrr1r2r)rrrrrdr3rqr4s r #_CreateBatchJobParameters_to_vertexrss !) +y!-   *d; :;  +w+ ! T+w-G H   +z".  ' xj )9  r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrIrJr4s r _GetBatchJobParameters_to_vertexrurMr"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrIrJr4s r #_CancelBatchJobParameters_to_vertexrw1rMr"ci}t|dgt|ddgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dg|S)NrQrRrSrTrUrVrrs r _ListBatchJobsConfig_to_vertexryDs!) + }%1*-tK+/O + ~&2 ; [<.)  +z".8,d; .KL r"c ji}t|dg#t|dgtt|dg||SrY)rrryrs r "_ListBatchJobsParameters_to_vertexr{\sF!) +z".  & xj )9  r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrIrJr4s r #_DeleteBatchJobParameters_to_vertexr}mrMr"ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|S)Nrrrrrrrs r _VideoMetadata_from_mldevrs!) +w+UGT+w78 + }%1\ND{m$DE + '3^$d;&HI r"ci}t|dgt|dgt|dgt|dgt|dgt|dg|S)Nr&r(r'rrs r _Blob_from_mldevrs[!) +x ,VHd;9: + |$0[M4 j\#BC r"ci}t|dgt|dgt|dgt|dgt|dgt|dg|S)Nr.r-r(r'rrs r _FileData_from_mldevrs[!) + {#/ZL${YK"@A + |$0[M4 j\#BC r"ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|Sr1rrs r _FunctionCall_from_mldevrr6r"c Ri}t|dg#t|dgtt|dg|t|dgt|dgt|dgt|dg#t|dgtt|dg|t|dg#t|dgt t|dg|t|dgt|d gt|dgt|d g#t|d gt t|d g|t|d gt|d gt|d gt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|S)Nr9r8r:r<r;r>r=r@r?rBrArDrCrFrErHrGrI)rrrrrrrs r _Part_from_mldevrs!) +()5 ! / 0)  + {#/YKkI;!?@ + ~&2 kL>:IF  + |$0  T+ |i}t|dg#t|dgtt|dg|t|dg#t|dgtt|dg|t|dgt|dgt|dgt|dgt|dgt|dgt|dg#t|d gt t|dg|t|d gt|d gt|d gt|d gt|d gt|d gt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|S)Nr?citationMetadatacitation_metadata tokenCount token_count finishReason finish_reasonurlContextMetadataurl_context_metadata avgLogprobs avg_logprobsgroundingMetadatagrounding_metadataindexlogprobsResultlogprobs_result safetyRatingssafety_ratings)rrrrrrs r _Candidate_from_mldevrJs!) + {#/  Dyk:IF  +*+,8 $ 12 3Y  + ~&2]OT+ ~%FG +'(4_%tK.9I'JK +,-.:  & 34 5y  + '3^$d;&HI ++,-9  [./0  +y!-WItK';< +()*6&'k r"c i}t|dg#t|dgtt|dg|t|dgt|dgt|dg|S)N embeddingrr)rrrrs r &_SingleEmbedContentResponse_from_mldevrsl!) + }%1  $ {m ,i  + ~&2]OT+ ~%FG r"c i}t|dg#t|dgtt|dg|t|dg#t|dgtt|dg||Sr)rrrrrs r '_InlinedEmbedContentResponse_from_mldevrsz!) + |$0  . zl +Y  +y!-  T+y99E r"c li}t|dgt|dgt|dgt|ddg2t|dgt|ddgDcgc]}t||c}t|ddg 2t|dgt|ddgDcgc]}t||c}|Scc}wcc}w)N responsesFiler#inlinedResponsesrkinlinedEmbedContentResponsesrl)rrrrrOs r _BatchJobDestination_from_mldevrs!) +()5[M4 o5F#GH +*,>?@L 02DE  (i 8   ;79KLM   *+/1CD  4D) D   1  s B, B1 c i}t|dgt|dgt|dgt|ddgt|dgt|ddgt|ddg-t|dgtjt|ddgt|ddgt|dgt|ddgt|ddgt|d gt|ddgt|dd gt|d gt|dd gt|dd gt|d gt|dd gt|dd g7t|dgt tj t|dd g||S)Nr4metadatar*r$state createTime create_timerr updateTime update_timeroutputr+)rrr t_job_statert_recv_batch_job_destinationrs r _BatchJob_from_mldevr/s!) +x ,VHd;9: + M23?  [:}56  + G,-9   d;W(=>?  + L12>  [:|45  + I./;ZL${Z4K"LM + L12>  [:|45  + G,-9WItK*g1FGH + H-.: ' * *[:x"89      r"c (i}t|dgt|dgt|dgt|dgt|dgt|dgt|dg1t|dgt|dgDcgc]}t||c}|Scc}w)Nrr nextPageTokennext_page_token operations batch_jobs)rrrrOs r !_ListBatchJobsResponse_from_mldevrhs!) +)*+7'(${=N?@  +-{;<H  [0+>? r"c i}t|dgt|dgt|dgt|dgt|dgt|dgt|dg,t|dgtjt|dgt|dg#t|dgt t|dg|t|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d gt|d gt|d gt|d gt|dgt|dgt|dgt|dg#t|dgt t|dg|t|dg6t|dgt tjt|dg||S)Nr4r*r$rrrrrrrrrrrr2r1ror+)rrrrrrrrrs r _BatchJob_from_vertexrs!) +x ,VHd;9: + '3^$d;&HI +y!-WIq}}T+y-IJK +y!-  d; :IF  + ~&2]OT+ ~%FG + }%1\ND{m$DE + {#/ZL${YK"@A + ~&2]OT+ ~%FG +y!-WItK';< + '3 # }o .   +'(4 ( * *4 n=M+N O   r"c (i}t|dgt|dgt|dgt|dgt|dgt|dgt|dg1t|dgt|dgDcgc]}t||c}|Scc}w)NrrrrbatchPredictionJobsr)rrrrOs r "_ListBatchJobsResponse_from_vertexrs!) +)*+7'(${=Nt |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| } | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } |jj1| | S Nrr1rr0r{model}:batchGenerateContentrR?rpostrkwargs)r _CreateBatchJobParameters _api_clientvertexairsget format_mapr5rpopr http_optionsr convert_to_dictencode_unserializable_typesrbodyjsonloadsrrBatchJob_from_response model_dump_verify_response selfrr1rparameter_model request_dictrequest_url_dictpath query_paramsrr response_dict return_values r _createzBatches._createKs55 O   8   Ol&))&1 $//0@A$7   Ol&))&1 -889IJ-##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''lLH'mmBHMM1JM   +M:m+=9m>>00'A'A'C1L %%l3 r"ctj|||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| } | j sd nt#j$| j } |jjs t'| } tj(j+| |j- } |jj/| | S Nrz=This method is only supported in the Gemini Developer client.r0{model}:asyncBatchEmbedContentrRrrrrr)r #_CreateEmbeddingsBatchJobParametersrrr*rGrrrrrrr rrrrr r rr r r rrs r _create_embeddingszBatches._create_embeddingss?? O    I B   Ol&))&1 /::;KL/##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''lLH'mmBHMM1JM    $ $*=9m>>00'A'A'C1L %%l3 r"rr4c tj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } |jj1| | S) a6Gets a batch job. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the Vertex AI client. Or "batches/abc" using the Gemini Developer AI client. Returns: A BatchJob object that contains details about the batch job. Usage: .. code-block:: python batch_job = client.batches.get(name='123456789') print(f"Batch job: {batch_job.name}, state {batch_job.state}") r4rr0batchPredictionJobs/{name}batches/{name}rRrrNrrr)r _GetBatchJobParametersrrrurrrLrrrrr rrrrr r rrr r r r rr4rrrrrrrrrrs r rz Batches.gets,22 O   5   Ol&))&1 +667GH+4   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''t\<PH&mmBHMM1JM   +M:m+=9m>>00'A'A'C1L %%l3 r"ctj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} y) aCancels a batch job. Only available for batch jobs that are running or pending. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the Vertex AI client. Or "batches/abc" using the Gemini Developer AI client. Usage: .. code-block:: python client.batches.cancel(name='123456789') r r0!batchPredictionJobs/{name}:cancelbatches/{name}:cancelrRrrNr)r _CancelBatchJobParametersrrrwrrrOrrrrr rrr rr4rrrrrrrrs r cancelzBatches.cancel sY.55 O   8   Ol&))&1 2==>NO27   Ol&))&1 &112BC&##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''lLHr"c(tj|}|jjr3t |}|j d}|rdj |}n5d}n2t|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||}|j sd nt#j$|j } |jjr t'| } n t)| } tj*j-| |j/ } tj0|j2 | _|jj7| | S Nrr0rbatchesrRrrrrrheaders)r _ListBatchJobsParametersrrr{rrrZrrrrr rrrrr r rrListBatchJobsResponser r  HttpResponser/rr rrrrrrrrrrrs r _listz Batches._list_ s44O    7Hl%))&1 $//0@A$6Gl%))&1 ##$45##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''t\<PH&mmBHMM1JM   8Gm8 Fm..=='A'A'C>L&+%7%7  &L" %%l3 r"cVtj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } tj0| j2 | _|jj7| | S) aDeletes a batch job. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the client. Returns: A DeleteResourceJob object that shows the status of the deletion. Usage: .. code-block:: python client.batches.delete(name='123456789') r r0r!r"rRrrNdeleterrr.)r _DeleteBatchJobParametersrrr}rrr\rrrrr rrrrr r rrDeleteResourceJobr r r2r/rrr$s r r6zBatches.delete s.55 O   8   Ol&))&1 +667GH+7   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''$ lH'mmBHMM1JM   4]Cm4MBm**99'A'A'C:L&+%7%7  &L" %%l3 r"c0tj|j|}tj|||}d}|j ,|j j |j j }|jjr4tj||j }|j|||S|j|j|||St|j|\}}|jjd|||}|jsdntj |j} t#| } tj$j'| |j)} |jj+| | S)aCreates a batch job. Args: model (str): The model to use for the batch job. src: The source of the batch job. Currently Vertex AI supports GCS URI(-s) or BigQuery URI. Example: "gs://path/to/input/data" or "bq://projectId.bqDatasetId.bqTableId". Gemini Developer API supports List of inlined_request, or file name. Example: "files/file_name". config (CreateBatchJobConfig): Optional configuration for the batch job. Returns: A BatchJob object that contains details about the batch job. Usage: .. code-block:: python batch_job = client.batches.create( model="gemini-2.0-flash-001", src="gs://path/to/input/data", ) print(batch_job.state) rNrrr)rr3rr rrrrr format_destinationrr%-_create_inlined_generate_content_request_dictrrr r rr r r r rrr1rrrrrrrrs r createzBatches.create sn<  t// 5C55 O 15L*  " " / / ;$++88l   ..sO4J4JKf \\3v\ >>   % \\3v\ >>F /D,''lLH'mmBHMM1JM(7M>>00'A'A'C1L %%l3 r"c*ddl}|jdtjdt j |j |}tj|||}d}|j,|jj|jj}|j jr td|j|j|||St|j |\}}|j j!d|||} | j"sd nt%j&| j"} t)| } tj*j-| |j/ } |j j1| | S) a]**Experimental** Creates an embedding batch job. Args: model (str): The model to use for the batch job. src: Gemini Developer API supports List of inlined_request, or file name. Example: "files/file_name". config (CreateBatchJobConfig): Optional configuration for the batch job. Returns: A BatchJob object that contains details about the batch job. Usage: .. code-block:: python batch_job = client.batches.create_embeddings( model="text-embedding-004", src="files/my_embedding_input", ) print(batch_job.state) rNJbatches.create_embeddings() is experimental and may change without notice.rx stacklevelr5Vertex AI does not support batches.create_embeddings.rrr)warningswarnr ExperimentalWarningrt_embedding_batch_job_sourcerr rrrrr*r%r&_create_inlined_embedding_request_dictrrr r rr r r r rrr1rrDrrrrrrrs r create_embeddingszBatches.create_embeddings4 sw8 MM ,,  ( ()9)93 ?C?? O 15L*  " " / / ;$++88l   N OO   %  $ $5c& $ II? /D,''lLH'mmBHMM1JM(7M>>00'A'A'C1L %%l3 r"c~|tj}td|j|j||S)aLists batch jobs. Args: config (ListBatchJobsConfig): Optional configuration for the list request. Returns: A Pager object that contains one page of batch jobs. When iterating over the pager, it automatically fetches the next page if there are more. Usage: .. code-block:: python batch_jobs = client.batches.list(config={"page_size": 10}) for batch_job in batch_jobs: print(f"Batch job: {batch_job.name}, state {batch_job.state}") rr)r ListBatchJobsConfigrr4rrs r listz Batches.list s?(~((*f   & !  r")__name__ __module__ __qualname__rstrrr BatchJobSourceUnionBatchJobSourceUnionDictCreateBatchJobConfigOrDictr rEmbeddingsBatchJobSourceOrDict$CreateEmbeddingsBatchJobConfigOrDictrGetBatchJobConfigOrDictrCancelBatchJobConfigOrDictr*ListBatchJobsConfigOrDictr1r4DeleteBatchJobConfigOrDictr8r6r=rJrrNrr"r rrIs` ";? Bc]B **E,I,II J B u778 B  ~~ BN"EI :c]:  / / : uAAB :  ~~ :zMQNN"*5+H+H"IN ~~Nh<@ B Bu778 B  BJDH8 ? ?@8 ""8|<@ S Su778 S   St<@ DD  ( ( D u778 D  ~~ DVFJ II  / / I uAAB I  ~~ IXDH ? ?@ U^^r"rc eZdZddddeedeejejfdeejdejfdZ ddddeedejdeejdejfdZdd d edeejdejfd Zdd d edeej"ddfd Zdd deej&dej(fd Zdd d edeej,dej.fdZdd dedejdeejdejfdZdd dedejdeejdejfdZdd deej&deejfdZy) AsyncBatchesNrrr1rrc*Ktj|||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| d{} | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } |jj1| | S7wr)r rrrrsrrr5rrrrr rr async_requestrr r rrr r r rrs r rzAsyncBatches._create s55 O   8   Ol&))&1 $//0@A$7   Ol&))&1 -889IJ-##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLH'mmBHMM1JM   +M:m+=9m>>00'A'A'C1L %%l3 #sE$H&H'B+HcKtj|||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| d{} | j sd nt#j$| j } |jjs t'| } tj(j+| |j- } |jj/| | S7wr)r rrrr*rGrrrrrrr rrr_rr r rr r r rrs r rzAsyncBatches._create_embeddings s?? O    I B   Ol&))&1 /::;KL/##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLH'mmBHMM1JM    $ $*=9m>>00'A'A'C1L %%l3 sD1G3G4BGrr4c(Ktj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } |jj1| | S7w) a@Gets a batch job. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the Vertex AI client. Or "batches/abc" using the Gemini Developer AI client. Returns: A BatchJob object that contains details about the batch job. Usage: .. code-block:: python batch_job = await client.aio.batches.get(name='123456789') print(f"Batch job: {batch_job.name}, state {batch_job.state}") r r0r!r"rRrrNrrr)r r#rrrurrrLrrrrr rrr_rr r rrr r r rr$s r rzAsyncBatches.get s,22 O   5   Ol&))&1 +667GH+4   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM   +M:m+=9m>>00'A'A'C1L %%l3 #sE#H%H&B+HcKtj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} y7w) aCancels a batch job. Only available for batch jobs that are running or pending. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the Vertex AI client. Or "batches/abc" using the Gemini Developer AI client. Usage: .. code-block:: python await client.aio.batches.cancel(name='123456789') r r0r&r'rRrrNr)r r(rrrwrrrOrrrrr rrr_r)s r r*zAsyncBatches.cancelq sg.55 O   8   Ol&))&1 2==>NO27   Ol&))&1 &112BC&##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLHsE#E-%E+&E-cDKtj|}|jjr3t |}|j d}|rdj |}n5d}n2t|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||d{}|j sd nt#j$|j } |jjr t'| } n t)| } tj*j-| |j/ } tj0|j2 | _|jj7| | S7ϭwr,)r r0rrr{rrrZrrrrr rrr_rr r rrr1r r r2r/rrr3s r r4zAsyncBatches._list s44O    7Hl%))&1 $//0@A$6Gl%))&1 ##$45##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM   8Gm8 Fm..=='A'A'C>L&+%7%7  &L" %%l3 'sE H HCH crKtj||}|jjr>t |j|}|j d}|rdj |}n@d}n=t|j|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sd nt#j$| j } |jjr t'| } n t)| } tj*j-| |j/ } tj0| j2 | _|jj7| | S7ϭw) aDeletes a batch job. Args: name (str): A fully-qualified BatchJob resource name or ID. Example: "projects/.../locations/.../batchPredictionJobs/456" or "456" when project and location are initialized in the client. Returns: A DeleteResourceJob object that shows the status of the deletion. Usage: .. code-block:: python await client.aio.batches.delete(name='123456789') r r0r!r"rRrrNr6rrr.)r r7rrr}rrr\rrrrr rrr_rr r rrr8r r r2r/rrr$s r r6zAsyncBatches.delete s .55 O   8   Ol&))&1 +667GH+7   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33$ lH'mmBHMM1JM   4]Cm4MBm**99'A'A'C:L&+%7%7  &L" %%l3 'sE#H7%H5&CH7ctKtj|j|}tj|||}d}|j ,|j j |j j }|jjr>00'A'A'C1L %%l3 )E D s7CF8F2'F8*F4+>F8)F6*B F84F86F8cZKddl}|jdtjdt j |j |}tj|||}d}|j,|jj|jj}|j jr td|j|j|||d{St|j |\}}|j j!d|||d{} | j"sd nt%j&| j"} t)| } tj*j-| |j/ } |j j1| | S77w) ao**Experimental** Creates an asynchronously embedding batch job. Args: model (str): The model to use for the batch job. src: Gemini Developer API supports inlined_requests, or file name. Example: "files/file_name". config (CreateBatchJobConfig): Optional configuration for the batch job. Returns: A BatchJob object that contains details about the batch job. Usage: .. code-block:: python batch_job = await client.aio.batches.create_embeddings( model="text-embedding-004", src="files/my_embedding_input", ) print(batch_job.state) rNr?r@rArrCrrr)rDrEr rFrrGrr rrrrr*r%rrHr_rr r rr r r rrIs r rJzAsyncBatches.create_embeddings s8 MM ,,  ( ()9)93 ?C?? O 15L*  " " / / ;$++88l   N OO   %**C*O OO? /D,%%33lLH'mmBHMM1JM(7M>>00'A'A'C1L %%l3 %P s%CF+F' >F+F)B F+)F+cK|tj}td|j|j|d{|S7 w)a(Lists batch jobs asynchronously. Args: config (ListBatchJobsConfig): Optional configuration for the list request. Returns: A Pager object that contains one page of batch jobs. When iterating over the pager, it automatically fetches the next page if there are more. Usage: .. code-block:: python batch_jobs = await client.aio.batches.list(config={'page_size': 5}) print(f"current page: {batch_jobs.page}") await batch_jobs_pager.next_page() print(f"next page: {batch_jobs_pager.page}") Nrr)r rLrr4rMs r rNzAsyncBatches.list sK*~((*f  jjj''   (s=A A A )rOrPrQrrRrr rSrTrUr rrVrWrrXrrYr*rZr1r4r[r8r6r=rJrrNrr"r r]r] s` ";? Bc]B **E,I,II J B u778 B  ~~ BN"EI :c]:  / / : uAAB :  ~~ :zMQPP"*5+H+H"IP ~~Pl<@ B Bu778 B  BJDH: ? ?@: "":@<@ S Su778 S   St<@ CC  ( ( C u778 C  ~~ CTFJ II  / / I uAAB I  ~~ IXDH ? ?@%..!r"r]clientrct||}|jd}|rdj|}nd}|jd}|r|dt|}|j ddt j |}t j|}g}|jd}|rgt|trW|jd}|rDt|tr4|jd} | r!t| tr| jd}g} |rP|D]K} | jd r'| j d } | d jd | i| j| M| |dddd<||fS) Nr0rrRrrr)r2r&rr) r5rrrrr rr isinstancedictupdateappend) rhrrrrrr& batch_dictinput_config_dict requests_dict new_requestsreqvalues r r;r; s "D o","%%f- ) 4 45E FD )D!!(+,V1Y|,- .D8T"((6,44\B,((*Jz40"}5Z(94@'++J7m :mT: $$Z0,  $ %+, I2E:;# w &z2 | r"c|j}t|tjst d|dt ||}|j d}|rdj|}nd}|j d}|r|dt|}|jdd|j dij d ij d ijddtj|}tj|}g}|j d}|rgt|trW|j d } | rDt| tr4| j d } | r!t| tr| j d }g} |rS|D]N} t| jD]} | d k7s | j| | d | <!| j!| P| |dd d d <||fS) NzInvalid batch job source: .r0rrRrrr)r2r&r)r1rjr EmbeddingsBatchJobSourcer*rGrrrrr rrrkrNkeysrm)rhrr1rrrrr&rnrorprqrrks r rHrH! s # C77 8 1#a8 99"N o","%%f- + 6 67G HD +D!!(+,V1Y|,- .D8T"7B##M26:::rJNN((6,44\B, ((*Jz40"}5Z(94@'++J7m :mT: $$Z0, CHHJ)! >!ggaj#i. )# w &z2 | r"r)qr loggingtypingrrr urllib.parserrrr r r rr rr rrrrpagersrr getLoggerloggerrkrRobjectr!r+r/r5rJrQrurzrrrrrrrrrrrrrrrrrrrrr'r-r5r=rArCrErGrLrOrWrZr\rdrmrqrsrurwryr{r}rrrrrrrrrrrrrrrrrrrrrrrrrr BaseModulerr]rtupler;rrHrr"r rs$ ''" &..%   1 2 /3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^&/3AtCH~v-.ADcN+A #s(^AL/3tCH~v-.DcN+ #s(^./3VtCH~v-.VDcN+V #s(^Vv/3tCH~v-.DcN+ #s(^&/3"tCH~v-."DcN+" #s(^"N/3 tCH~v-. DcN+  #s(^  /3tCH~v-.DcN+ #s(^,/3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^/3=tCH~v-.=DcN+= #s(^=D/3tCH~v-.DcN+ #s(^(/3 tCH~v-. DcN+  #s(^  /3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^8/3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^:/3 tCH~v-. DcN+  #s(^ &/3ggtCH~v-.gDcN+g #s(^ gZ/3  tCH~v-. DcN+  #s(^ L/3tCH~v-.DcN+ #s(^ B/3tCH~v-.DcN+ #s(^,/3!!tCH~v-.!DcN+! #s(^ !L/3tCH~v-.DcN+ #s(^F/3tCH~v-.DcN+ #s(^ 4/3tCH~v-.DcN+ #s(^ ./3 tCH~v-. DcN+  #s(^ &/3tCH~v-.DcN+ #s(^ J/3tCH~v-.DcN+ #s(^ ,/3tCH~v-.DcN+ #s(^ */3tCH~v-.DcN+ #s(^4/3 tCH~v-. DcN+  #s(^ $/3tCH~v-.DcN+ #s(^ */3tCH~v-.DcN+ #s(^>/3$tCH~v-.$DcN+$ #s(^$R/3tCH~v-.DcN+ #s(^0/3  tCH~v-. DcN+  #s(^ L/3tCH~v-.DcN+ #s(^ ,/3tCH~v-.DcN+ #s(^ */3tCH~v-.DcN+ #s(^4/3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^ */3tCH~v-.DcN+ #s(^&/3 tCH~v-. DcN+  #s(^ "/3 tCH~v-. DcN+  #s(^ "/3tCH~v-.DcN+ #s(^&/3CtCH~v-.CDcN+C #s(^CP/3tCH~v-.DcN+ #s(^./3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^(/3tCH~v-.DcN+ #s(^(/37tCH~v-.7DcN+7 #s(^7x/3 tCH~v-. DcN+  #s(^ J/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^4/3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^,/3tCH~v-.DcN+ #s(^4/3%tCH~v-.%DcN+% #s(^%T/36tCH~v-.6DcN+6 #s(^6v/3tCH~v-.DcN+ #s(^8/3tCH~v-.DcN+ #s(^8/3tCH~v-.DcN+ #s(^&/3tCH~v-.DcN+ #s(^./3tCH~v-.DcN+ #s(^6/37tCH~v-.7DcN+7 #s(^7x/3tCH~v-.DcN+ #s(^8/3tCH~v-.DcN+ #s(^4Q k$$Q hU ;))U p) ),1,K,K) 3S#X )X2 2>>2 3S#X 2r"