Li& ddlZddlZddlmZmZmZddlmZddlm Z ddlm Z ddlm Z ddlm Z dd lmZdd lmZdd l mZdd l mZdd l mZddlmZmZej4dZ dEdeeeefefdeeeefdeeeffdZ dEdeeeefefdeeeefdeeeffdZ dEdeeeefefdeeeefdeeeffdZ! dEdeeeefefdeeeefdeeeffdZ" dEdedeeeefefdeeeefdeeeffdZ# dEdeeeefefdeeeefdeeeffdZ$ dEdeeeefefdeeeefdeeeffdZ% dEdeeeefefdeeeefdeeeffdZ& dEdeeeefefdeeeefdeeeffdZ' dEdedeeeefefdeeeefdeeeffdZ( dEdedeeeefefdeeeefdeeeffdZ) dEdeeeefefdeeeefdeeeffdZ* dEdeeeefefdeeeefdeeeffd Z+ dEdeeeefefdeeeefdeeeffd!Z, dEdeeeefefdeeeefdeeeffd"Z- dEdeeeefefdeeeefdeeeffd#Z. dEdedeeeefefdeeeefdeeeffd$Z/ dEdedeeeefefdeeeefdeeeffd%Z0 dEdeeeefefdeeeefdeeeffd&Z1 dEdedeeeefefdeeeefdeeeffd'Z2 dEdedeeeefefdeeeefdeeeffd(Z3 dEdedeeeefefdeeeefdeeeffd)Z4 dEdeeeefefdeeeefdeeeffd*Z5 dEdeeeefefdeeeefdeeeffd+Z6 dEdedeeeefefdeeeefdeeeffd,Z7 dEdeeeefefdeeeefdeeeffd-Z8 dEdedeeeefefdeeeefdeeeffd.Z9 dEdeeeefefdeeeefdeeeffd/Z: dEdedeeeefefdeeeefdeeeffd0Z; dEdeeeefefdeeeefdeeeffd1Z< dEdedeeeefefdeeeefdeeeffd2Z= dEdedeeeefefdeeeefdeeeffd3Z> dEdeeeefefdeeeefdeeeffd4Z? dEdeeeefefdeeeefdeeeffd5Z@ dEdedeeeefefdeeeefdeeeffd6ZA dEdeeeefefdeeeefdeeeffd7ZB dEdeeeefefdeeeefdeeeffd8ZC dEdeeeefefdeeeefdeeeffd9ZD dEdeeeefefdeeeefdeeeffd:ZE dEdeeeefefdeeeefdeeeffd;ZF dEdeeeefefdeeeefdeeeffd<ZG dEdeeeefefdeeeefdeeeffd=ZH dEdeeeefefdeeeefdeeeffd>ZI dEdeeeefefdeeeefdeeeffd?ZJ dEdeeeefefdeeeefdeeeffd@ZKGdAdBe jZMGdCdDe jZNy)FN)AnyOptionalUnion) urlencode) _api_module)_common) _extra_utils) _transformers)types) BaseApiClient)get_value_by_path)move_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.batches from_object parent_objectreturnc Xi}t|dgt|dgt|dgt|ddg2t|dgt|ddgDcgc]}t||c}t|ddg (t|dgt|ddgDcgc]}|c}|Scc}wcc}w)N responsesFile file_nameinlinedResponsesinlined_responsesinlinedEmbedContentResponsesinlined_embed_content_responses)getvsetv_InlinedResponse_from_mldevrr to_objectitems R/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/google/genai/batches.py_BatchJobDestination_from_mldevr$&s!) +()5[M4 o5F#GH +*,>?@L 02DE  (i 8   ;79KLM   *+/1CD     1  s B"  B' c i}t|dgt|dgt|dgt|ddgt|dgt|ddgt|ddgt|dgt|ddg|S) NpredictionsFormatformatgcsDestinationoutputUriPrefixgcs_uribigqueryDestination outputUri bigquery_urirrrrr!s r# _BatchJobDestination_from_vertexr0Ns!) ++,-9XJ[3F2G HI +(*;<=I   [+->?@  +-{;<H  [0+>? ci}t|dgt|dgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|d g td t|d g td t|d g td|S)Nr'r&r*r(r)r-r+r,r2file_name parameter is not supported in Vertex AI.rz:inlined_responses parameter is not supported in Vertex AI.rzHinlined_embed_content_responses parameter is not supported in Vertex AI.rr ValueErrorr/s r#_BatchJobDestination_to_vertexr6gs!) +z".()4 hZ+HI + {#/ ,- [9+&  +'(4  , [>*+  + }%1 I JJ ++,-9 D  +9:;G    r1c i}t|dgt|dgt|dgt|ddgt|dgt|ddgt|ddgt|dgt|ddg|S) NinstancesFormatr' gcsSourceurisr*bigquerySourceinputUrir-r.r/s r#_BatchJobSource_from_vertexr=s!) +)*+7XJ[3D2E FG + V,-9YKkK3H!IJ +(*56B  [+Z89 r1 api_clientc 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.r*z1gcs_uri parameter is not supported in Gemini API.r-z6bigquery_uri parameter is not supported in Gemini API.rfileNameinlined_requestsrequests)rr5r_InlinedRequest_to_mldevr>rrr!r"s r#_BatchJobSource_to_mldevrEs !) +z". G HH + {#/ H II +'(4 M NN + }%1ZL${[M"BC +*+,8 Z [+=*>?  %Zy A    sB3 cRi}t|dgt|dgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|d g td t|d g td |S) Nr'r8r*r9r:r-r;r<rr3rAz9inlined_requests parameter is not supported in Vertex AI.r4r/s r#_BatchJobSource_to_vertexrGs!) +z".&'kH:)FG + {#/[&)4 i[+IJ +'(4 :& [>*+  + }%1 I JJ +*+,8 C  r1c 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)Nnamemetadata displayName display_namestate createTime create_timeendTimeend_time updateTime update_timemodeloutputdest)rrt t_job_stater$t_recv_batch_job_destinationr/s r#_BatchJob_from_mldevrZs!) +x ,VHd;9: + M23?  [:}56  + G,-9   d;W(=>?  + L12>  [:|45  + I./;ZL${Z4K"LM + L12>  [:|45  + G,-9WItK*g1FGH + H-.: ' * *[:x"89      r1c i}t|dgt|dgt|dgt|dgt|dgt|dgt|dg,t|dgtjt|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|dg#t|dgt t|dg|t|dg6t|dgt tj t|dg|t|dgt|dgt|dg|S)NrIrKrLrMerrorrNrO startTime start_timerPrQrRrSrT inputConfigsrc outputConfigrVcompletionStatscompletion_stats)rrrWrXr=r0rYr/s r#_BatchJob_from_vertexrds!) +x ,VHd;9: + '3^$d;&HI +y!-WIq}}T+y-IJK +y!-WItK';< + ~&2]OT+ ~%FG + }%1\ND{m$DE + {#/ZL${YK"@A + ~&2]OT+ ~%FG +y!-WItK';< + '3 # }o .   +'(4 ( * *4 n=M+N O   +)*+7&'krrr!s r#"_CancelBatchJobParameters_to_mldevrqdL !) +x ,  :tK&'BC r1c i}t|dg.t|ddgtj|t|dg|Srlrnrps r##_CancelBatchJobParameters_to_vertexrttrrr1c <i}t|dgt|dgt|dgt|dg#t|dgtt|dg|t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d gt|d gt|d gt|d gt|d gt|dgt|d gt|dg't|dgt|dgDcgc]}|c}t|dgt|dgt|dg|Scc}w)NcontentcitationMetadatacitation_metadata tokenCount token_count finishReason finish_reason avgLogprobs avg_logprobsgroundingMetadatagrounding_metadataindexlogprobsResultlogprobs_result safetyRatingssafety_ratingsurlContextMetadataurl_context_metadata)rr_CitationMetadata_from_mldevr s r#_Candidate_from_mldevrs!) + {#/YKkI;!?@ +*+,8 $ 12 3Y  + ~&2]OT+ ~%FG +'(4_%tK.9I'JK + '3^$d;&HI ++,-9  [./0  +y!-WItK';< +()*6&'k?$?  +,-.:   [/01  @s! F c|i}t|dg't|dgt|dgDcgc]}|c}|Scc}w)NcitationSources citationsr.r s r#rrsQ!) +)*+7  {->,?@A$A  Bs 9 c i}t|dg1t|dgt|dgDcgc]}t||c}t|dgt|dgt|dg|Scc}w)Npartsrole)rr_Part_to_mldevr s r#_Content_to_mldevrs!) +y!-  [7)4  4 +  +x ,VHd;9:  sA) ci}t|dgt|ddgt|dgt|dg td|S)NrLbatchrKrVz.dest parameter is not supported in Gemini API.r4r/s r#_CreateBatchJobConfig_to_mldevrs\!) +'(4 -  [>*+  +x , E FF r1c i}t|dgt|dgt|dgt|dg6t|dgttjt|dg||S)NrLrKrVra)rrr6rWt_batch_job_destinationr/s r#_CreateBatchJobConfig_to_vertexrsz!) +'(4kN;K)LM +x , & % %d;&A BI  r1cTi}t|dg.t|ddgtj|t|dgt|dg9t|ddgt |tj |t|dg|t|dgt t|dg||SNrTrmr`rr_config)rrrWt_modelrEt_batch_job_sourcerrps r#"_CreateBatchJobParameters_to_mldevrs !) +y!-  *d; :;  +w+ -   T+w-G H   +z"."4 hZ#@)L r1c Ni}t|dg-t|dgtj|t|dgt|dg7t|dgt tj |t|dg|t|dgt t|dg||S)NrTr`r_r)rrrWrrGrrrps r##_CreateBatchJobParameters_to_vertexr&s !) +y!-   *d; :;  +w+ ! T+w-G H   +z".#Dxj$A9M r1cXi}t|dgt|ddgt|dg|S)NrLrrKr.r/s r#(_CreateEmbeddingsBatchJobConfig_to_mldevrCsA!) +'(4 -  [>*+ r1c ,i}t|dg.t|ddgtj|t|dgt|dg%t|ddgt |t|dg|t|dgt t|dg||Sr)rrrWr"_EmbeddingsBatchJobSource_to_mldevrrps r#,_CreateEmbeddingsBatchJobParameters_to_mldevrSs !) +y!-  *d; :;  +w+ - * [5'2I  +z"., [8*%y r1c i}t|dg.t|ddgtj|t|dg|Srlrnrps r#"_DeleteBatchJobParameters_to_mldevrqrrr1c i}t|dg.t|ddgtj|t|dg|Srlrnrps r##_DeleteBatchJobParameters_to_vertexrrrr1c:i}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|SNsdkHttpResponsesdk_http_responserIdoner\r.r/s r#_DeleteResourceJob_from_mldevr!) +)*+7'(${=N  s B cTi}t|dgt|ddgt|dgt|dgt|ddgt|dgt|dgt|ddgt|dgt|dg tdt|d g td |S) N task_typertaskTypetitleoutput_dimensionalityoutputDimensionalityrhz3mime_type parameter is not supported in Gemini API. auto_truncatez7auto_truncate parameter is not supported in Gemini API.r4r/s r#rrs!) + }%1 z" [;-(  +y!-w/kG91MN +/01= -. [234  + }%1 J KK +()5 N OO r1c i}t|dgt|dgt|dgt|dg$t|dgt|t|dg||S)NrrArB)rrrrps r#rrsr !) + }%1[M4 k]#CD +*+,8  # [+=*>?  r1ci}t|dg tdt|dgt|dgt|dgt|dgt|dgt|dg|S)NrLrgfile_urifileUrirhrirr5rr/s r#_FileData_to_mldevrsw!) +'(4 M NN + |$0YKkJ J  +)*+7 [+<*=>  $D) 4  +y!-   *d; .JK  188J5y A  + '3[=/(JK +z". G HH +()*6   [+;*<=  +-./;  [012  +*+,8%&[;M:N(O +()5  ${_,=>?  +)*+7 C  +)*+7%&[;L:M(NO +'(4]OT+7G%HI {  s R% 'R* c  i}t|dgt|dgt|dgt|dg1t|dgt|dgDcgc]}t||c}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d g|Scc}w) Nrr candidates modelVersion model_versionpromptFeedbackprompt_feedback responseId response_id usageMetadatausage_metadata)rrrr s r##_GenerateContentResponse_from_mldevr s3!) +)*+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 sint#j$| j } |jjr t'| } |jjs t)| } tj*j-| |j/ } |jj1| | S NrTr`rrmr9z{model}:batchGenerateContentr$?rpostr!kwargs)r _CreateBatchJobParameters _api_clientvertexairget format_maprrpopr http_optionsr convert_to_dictencode_unserializable_typesrbodyjsonloadsrdrZBatchJob_from_response model_dump_verify_response selfrTr`rparameter_model request_dictrequest_url_dictpath query_paramsrur! response_dict return_values r#_createzBatches._create`s55 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 r1ctj|||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| } | j sint#j$| j } |jjs t'| } tj(j+| |j- } |jj/| | S Nrjz=This method is only supported in the Gemini Developer client.rmz{model}:asyncBatchEmbedContentr$rkrrlrm)r #_CreateEmbeddingsBatchJobParametersrprqr5rrrrsrrtrrur rvrwrrxryrzrZr{r|r}r~rs 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 r1rrIc6tj||}|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 sint#j$| j } |jjr t'| } |jjs 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}") rIrrmbatchPredictionJobs/{name}batches/{name}r$rkrNrrrm)r _GetBatchJobParametersrprqrrrrsrrrtrrur rvrwrrxryrzrdrZr{r|r}r~ rrIrrrrrrrur!rrs r#rrz 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 r1ctj||}|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') rrm!batchPredictionJobs/{name}:cancelbatches/{name}:cancelr$rkrNrl)r _CancelBatchJobParametersrprqrtrrrsrqrrtrrur rvrwr rrIrrrrrrrur!s r#cancelzBatches.cancel0sY.55 O   8   Ol&))&1 2==>NO27   Ol&))&1 &112BC&##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''lLHr1cRtj|}|jjr3t |}|j d}|rdj |}n5d}n2t|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||}|j sint#j$|j } |jjr t'| } |jjs t)| } tj*j-| |j/ } tj0|j2 | _|jj7| | S Nrrmr9batchesr$rkrrrrmheaders)r _ListBatchJobsParametersrprqr0rrrsr.rrtrrur rvrwrrxryrzr:r6ListBatchJobsResponser|r} HttpResponserrr~ rrrrrrrrur!rrs r#_listz Batches._listts44O    7Hl%))&1 $//0@A$6Gl%))&1 ##$45##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''t\<PH&mmBHMM1JM   8Gm    $ $7 Fm..=='A'A'C>L&+%7%7  &L" %%l3 r1ctj||}|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 sint#j$| j } |jjr t'| } |jjs 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') rrmrrr$rkrNdeletermr)r _DeleteBatchJobParametersrprqrrrrsrrrtrrur rvrwrrxryrzrrDeleteResourceJobr|r}rrrr~rs r#rzBatches.deletes .55 O   8   Ol&))&1 +667GH+7   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''$ lH'mmBHMM1JM   4]Cm    $ $3MBm**99'A'A'C:L&+%7%7  &L" %%l3 r1c.tj|j|}tj|||}|jj r4t j||j}|j|||S|j|||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) rj rWrrpr rorqr format_destinationrrrrTr`rrs r#createzBatches.creates<  t// 5C55 O    ..sO4J4JKf \\3v\ >> \\3v\ >>r1c(ddl}|jdtjdt j |j |}tj|||}|j jr td|j|||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.rO stacklevelrj5Vertex AI does not support batches.create_embeddings.) warningswarnr ExperimentalWarningrWt_embedding_batch_job_sourcerpr rrqr5r)rrTr`rrrs r#create_embeddingszBatches.create_embeddings0s8 MM ,,  ( ()9)93 ?C?? O    N OO  $ $5c& $ IIr1c~|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}") r5r)r ListBatchJobsConfigrrrrs r#listz Batches.listbs?(~((*f   & !  r1)__name__ __module__ __qualname__rstrrr BatchJobSourceUnionBatchJobSourceUnionDictCreateBatchJobConfigOrDictr{rEmbeddingsBatchJobSourceOrDict$CreateEmbeddingsBatchJobConfigOrDictrGetBatchJobConfigOrDictrrCancelBatchJobConfigOrDictrListBatchJobsConfigOrDictrrDeleteBatchJobConfigOrDictrrrrrrr1r#rfrf^s[ ";? 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<@ +?+?  ( ( +? u778 +?  ~~ +?dFJ 0J0J  / / 0J uAAB 0J  ~~ 0JfDH ? ?@ U^^r1rfc eZdZddddeedeejejfdeejdejfdZ ddddeedejdeejdejfdZdd d edeejdejfd Zdd d edeej"ddfd Zdd deej&dej(fd Zdd d edeej,dej.fdZdd dedejdeejdejfdZdd dedejdeejdejfdZdd deej&deejfdZy) AsyncBatchesNrgrTr`rrcTKtj|||}|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 sint#j$| j } |jjr t'| } |jjs t)| } tj*j-| |j/ } |jj1| | S7wri)r rorprqrrrrsrrrtrrur rvrw async_requestrxryrzrdrZr{r|r}r~rs r#rzAsyncBatches._creates55 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&'CH(cKtj|||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd} |j,|jj|jj} tj|}tj|}|jjd||| d{} | j sint#j$| j } |jjs t'| } tj(j+| |j- } |jj/| | S7wr)r rrprqr5rrrrsrrtrrur rvrwrrxryrzrZr{r|r}r~rs r#rzAsyncBatches._create_embeddingss?? O    I B   Ol&))&1 /::;KL/##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLH'mmBHMM1JM    $ $*=9m>>00'A'A'C1L %%l3 sD1G3G4BGrrIcRKtj||}|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 sint#j$| j } |jjr t'| } |jjs 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}") rrmrrr$rkrNrrrm)r rrprqrrrrsrrrtrrur rvrwrrxryrzrdrZr{r|r}r~rs r#rrzAsyncBatches.gets,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%&CH'cKtj||}|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') rrmrrr$rkrNrl)r rrprqrtrrrsrqrrtrrur rvrwrrs r#rzAsyncBatches.cancelTsg.55 O   8   Ol&))&1 2==>NO27   Ol&))&1 &112BC&##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLHsE#E-%E+&E-cnKtj|}|jjr3t |}|j d}|rdj |}n5d}n2t|}|j d}|rdj |}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||d{}|j sint#j$|j } |jjr t'| } |jjs t)| } tj*j-| |j/ } tj0|j2 | _|jj7| | S7wr)r rrprqr0rrrsr.rrtrrur rvrwrrxryrzr:r6rr|r}rrrr~rs r#rzAsyncBatches._lists44O    7Hl%))&1 $//0@A$6Gl%))&1 ##$45##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM   8Gm    $ $7 Fm..=='A'A'C>L&+%7%7  &L" %%l3 'sE H5H3C%H5cKtj||}|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 sint#j$| j } |jjr t'| } |jjs t)| } tj*j-| |j/ } tj0| j2 | _|jj7| | S7w) 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') rrmrrr$rkrNrrmr)r rrprqrrrrsrrrtrrur rvrwrrxryrzrrrr|r}rrrr~rs r#rzAsyncBatches.deletes.55 O   8   Ol&))&1 +667GH+7   Ol&))&1 **+;<##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33$ lH'mmBHMM1JM   4]Cm    $ $3MBm**99'A'A'C:L&+%7%7  &L" %%l3 'sE#I %I &C%I c^Ktj|j|}tj|||}|jj rrs@$ ''" &.0.%   1 2 /3%tCH~v-.%DcN+% #s(^%T/3tCH~v-.DcN+ #s(^6/3$tCH~v-.$DcN+$ #s(^$R/3tCH~v-.DcN+ #s(^0/3tCH~v-.DcN+ #s(^ B/3tCH~v-.DcN+ #s(^>/36tCH~v-.6DcN+6 #s(^6v/38tCH~v-.8DcN+8 #s(^8z/3tCH~v-.DcN+ #s(^(/3  tCH~v-. DcN+  #s(^ &/3  tCH~v-. DcN+  #s(^ $/35tCH~v-.5DcN+5 #s(^5t/3 tCH~v-. DcN+  #s(^ "/3tCH~v-.DcN+ #s(^./3tCH~v-.DcN+ #s(^*/3tCH~v-.DcN+ #s(^0/3tCH~v-.DcN+ #s(^ B/3tCH~v-.DcN+ #s(^ >/3 tCH~v-. DcN+  #s(^ &/3tCH~v-.DcN+ #s(^ B/3  tCH~v-. DcN+  #s(^ &/3  tCH~v-. DcN+  #s(^ $/3tCH~v-.DcN+ #s(^0/3tCH~v-.DcN+ #s(^2/3tCH~v-.DcN+ #s(^ </3tCH~v-.DcN+ #s(^F/3tCH~v-.DcN+ #s(^ ./3tCH~v-.DcN+ #s(^(/3[[tCH~v-.[DcN+[ #s(^ [@/3 tCH~v-. DcN+  #s(^ L/3  tCH~v-. DcN+  #s(^ &/3  tCH~v-. DcN+  #s(^ $/3 tCH~v-. DcN+  #s(^  /3tCH~v-.DcN+ #s(^4/3%%tCH~v-.%DcN+% #s(^ %T/3tCH~v-.DcN+ #s(^,/3tCH~v-.DcN+ #s(^4/3tCH~v-.DcN+ #s(^4/3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^8/3tCH~v-.DcN+ #s(^8/37tCH~v-.7DcN+7 #s(^7x/3tCH~v-.DcN+ #s(^&/35tCH~v-.5DcN+5 #s(^5p_k$$_Dj;))jr1