o ThG @sddlZddlZddlmZmZmZddlmZddlm Z ddlm Z ddlm Z ddlm Z dd lmZdd lmZdd l mZdd l mZdd lmZmZedZ d5deeeefefdeeeefdeeeffddZ d5deeeefefdeeeefdeeeffddZ d5deeeefefdeeeefdeeeffddZ d5dedeeeefefdeeeefdeeeffddZ d5dedeeeefefdeeeefdeeeffddZ! d5dedeeeefefdeeeefdeeeffddZ" d5deeeefefdeeeefdeeeffdd Z# d5deeeefefdeeeefdeeeffd!d"Z$ d5dedeeeefefdeeeefdeeeffd#d$Z% d5deeeefefdeeeefdeeeffd%d&Z& d5deeeefefdeeeefdeeeffd'd(Z' d5deeeefefdeeeefdeeeffd)d*Z( d5deeeefefdeeeefdeeeffd+d,Z) d5deeeefefdeeeefdeeeffd-d.Z* d5deeeefefdeeeefdeeeffd/d0Z+Gd1d2d2e j,Z-Gd3d4d4e j,Z.dS)6N)AnyOptionalUnion) urlencode) _api_module)_common) _extra_utils) _transformers)types) BaseApiClient)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.batches from_object parent_objectreturncC~i}t|dgdurt|dgt|dgt|dgdur)t|ddgt|dgt|dgdur=t|ddgt|dg|S) NformatinstancesFormatgcs_uri gcsSourceuris bigquery_uribigquerySourceinputUrigetvsetvrr to_objectr"W/home/air/segue/gemini/backup/venv/lib/python3.10/site-packages/google/genai/batches.py_BatchJobSource_to_vertex$s r$cCr) NrpredictionsFormatrgcsDestinationoutputUriPrefixrbigqueryDestination outputUrirr r"r"r#_BatchJobDestination_to_vertex9s   r*c Cs`i}t|dgdurt|dgt|dgt|dgdur.t|dgttt|dg||S)N display_name displayNamedest outputConfig)rrr*tt_batch_job_destinationr r"r"r#_CreateBatchJobConfig_to_vertexRsr1 api_clientc Csi}t|dgdurt|dgt|t|dgt|dgdur2t|dgttt|dg|t|dgdurHt|dgtt|dg||S)Nmodelsrc inputConfigconfig)rrr/t_modelr$t_batch_job_sourcer1r2rrr!r"r"r##_CreateBatchJobParameters_to_vertexgs0 r:c C^i}t|dgdurt|ddgt|t|dgt|dgdur-t|dgt|dg|SNname_urlr6rrr/t_batch_job_namer9r"r"r# _GetBatchJobParameters_to_vertexrAc Cr;r<r?r9r"r"r##_CancelBatchJobParameters_to_vertexrBrCcCsi}t|dgdurt|ddgt|dgt|dgdur*t|ddgt|dgt|dgdur>t|ddgt|dg|S)N page_size_querypageSize page_token pageTokenfilterrr r"r"r#_ListBatchJobsConfig_to_vertexs rJcCs4i}t|dgdurt|dgtt|dg||S)Nr6)rrrJr r"r"r#"_ListBatchJobsParameters_to_vertexs rKc Cr;r<r?r9r"r"r##_DeleteBatchJobParameters_to_vertexrBrLcCszi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur;t|dgt|dg|S)Ndetailscodemessagerr r"r"r#_JobError_from_vertexsrPcCi}t|dgdurt|dgt|dgt|ddgdur*t|dgt|ddgt|ddgdur?t|dgt|ddg|S) Nrrrrrrrrrr r"r"r#_BatchJobSource_from_vertexs rRcCrQ) Nr%rr&r'rr(r)rrr r"r"r# _BatchJobDestination_from_vertexs   rScCsi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur;t|dgt|dgt|dgdurQt|dgtt|dg|t|dgdurdt|dgt|dgt|dgdurwt|d gt|dgt|d gdurt|d gt|d gt|d gdurt|d gt|d gt|dgdurt|dgt|dgt|dgdurt|dgtt|dg|t|dgdurt|dgtt|dg||S)Nr=r,r+stateerror createTime create_time startTime start_timeendTimeend_time updateTime update_timer3r5r4r.r-)rrrPrRrSr r"r"r#_BatchJob_from_vertex*sP  r^csbit|dgdurtdgt|dgt|dgdur/tdgfddt|dgDS)N nextPageTokennext_page_tokenbatchPredictionJobs batch_jobscsg|]}t|qSr")r^).0itemr!r"r# osz6_ListBatchJobsResponse_from_vertex..r)rrr"rer#"_ListBatchJobsResponse_from_vertexcs   rgcCsi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur>t|dgtt|dg||S)Nr=donerU)rrrPr r"r"r#_DeleteResourceJob_from_vertexxsric @eZdZdddededeejdejfddZddd edeej dejfd d Z ddd edeej ddfd d Z dej dejfddZddd edeejdejfddZdddededeejdejfddZdddeej deejfddZdS)BatchesNr6r3r4r6rc Cstj|||d}|jjstdt|j|}|d}|r#d|}nd}|d}|r5|dt|}| ddd} |j durL|j j durL|j j } t |}t |}|jd||| } | jsdd nt| j} |jjrrt| } tjj| |d } |j| | S Nr3r4r66This method is only supported in the Vertex AI client.r>rarE?r6postresponsekwargs)r _CreateBatchJobParameters _api_clientvertexai ValueErrorr:get format_maprpopr6 http_optionsrconvert_to_dictencode_unserializable_typesrequestbodyjsonloadsr^BatchJob_from_response model_dump_verify_response selfr3r4r6parameter_model request_dictrequest_url_dictpath query_paramsr}rt response_dict return_valuer"r"r#_createsF         zBatches._creater=c Ctj||d}|jjstdt|j|}|d}|r"d|}nd}|d}|r4|dt|}| ddd}|j durK|j j durK|j j }t |}t |}|jd |||} | jscd nt| j} |jjrqt| } tjj| |d } |j| | S) aGets 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 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}") r=r6ror>batchPredictionJobs/{name}rErpr6Nrzrrrs)r _GetBatchJobParametersrwrxryrArzr{rr|r6r}rr~rrrrrr^rrrr rr=r6rrrrrr}rtrrr"r"r#rzs@         z Batches.getc Cstj||d}|jjstdt|j|}|d}|r"d|}nd}|d}|r4|dt|}| ddd}|j durK|j j durK|j j }t |}t |}|jd |||} dS) 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/123456789" or "123456789" when project and location are initialized in the client. Usage: .. code-block:: python client.batches.cancel(name='123456789') rror>!batchPredictionJobs/{name}:cancelrErpr6Nrq)r _CancelBatchJobParametersrwrxryrCrzr{rr|r6r}rr~rr rr=r6rrrrrr}rtr"r"r#cancel s4        zBatches.cancelc Cstj|d}|jjstdt|}|d}|rd|}nd}|d}|r1|dt|}| ddd}|j durH|j j durH|j j }t |}t |}|jd|||}|js`d nt|j} |jjrnt| } tjj| |d } |j| | S Nrlror>rarErpr6rzrrrs)r _ListBatchJobsParametersrwrxryrKrzr{rr|r6r}rr~rrrrrrgListBatchJobsResponserrr rr6rrrrrr}rtrrr"r"r#_listHs:         z Batches._listc Cr) 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') rror>rrErpr6Ndeleterrrs)r _DeleteBatchJobParametersrwrxryrLrzr{rr|r6r}rr~rrrrrriDeleteResourceJobrrrrr"r"r#rwsD         zBatches.deletecCst||}|j|||dS)aCreates a batch job. Args: model (str): The model to use for the batch job. src (str): The source of the batch job. Currently supports GCS URI(-s) or BigQuery URI. Example: "gs://path/to/input/data" or "bq://projectId.bqDatasetId.bqTableId". 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) rnr format_destinationrrr3r4r6r"r"r#creates zBatches.createcCs(|durt}td|j|j|d|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}") Nrbrl)r ListBatchJobsConfigrrrr6r"r"r#lists z Batches.list)__name__ __module__ __qualname__strrr CreateBatchJobConfigOrDictrrGetBatchJobConfigOrDictrzCancelBatchJobConfigOrDictrListBatchJobsConfigOrDictrrDeleteBatchJobConfigOrDictrrrrrr"r"r"r#rksp : H < 3 M !rkc @rj) AsyncBatchesNrlr3r4r6rc stj|||d}|jjstdt|j|}|d}|r$d|}nd}|d}|r6|dt|}| ddd} |j durM|j j durM|j j } t |}t |}|jd||| IdH} | jshd nt| j} |jjrvt| } tjj| |d } |j| | Srm)r rvrwrxryr:rzr{rr|r6r}rr~r async_requestrrrr^rrrrrr"r"r#rsH          zAsyncBatches._creater=c tj||d}|jjstdt|j|}|d}|r#d|}nd}|d}|r5|dt|}| ddd}|j durL|j j durL|j j }t |}t |}|jd |||IdH} | jsgd nt| j} |jjrut| } tjj| |d } |j| | S) aGets 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 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}") rror>rrErpr6Nrzrrrs)r rrwrxryrArzr{rr|r6r}rr~rrrrrr^rrrrrr"r"r#rz8sF          zAsyncBatches.getc stj||d}|jjstdt|j|}|d}|r#d|}nd}|d}|r5|dt|}| ddd}|j durL|j j durL|j j }t |}t |}|jd |||IdH} dS) 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/123456789" or "123456789" when project and location are initialized in the client. Usage: .. code-block:: python await client.aio.batches.cancel(name='123456789') rror>rrErpr6Nrq)r rrwrxryrCrzr{rr|r6r}rr~rrrr"r"r#r~s6        zAsyncBatches.cancelc stj|d}|jjstdt|}|d}|r d|}nd}|d}|r2|dt|}| ddd}|j durI|j j durI|j j }t |}t |}|jd|||IdH}|jsdd nt|j} |jjrrt| } tjj| |d } |j| | Sr)r rrwrxryrKrzr{rr|r6r}rr~rrrrrrgrrrrrr"r"r#rs@          zAsyncBatches._listc r) 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') rror>rrErpr6Nrrrrs)r rrwrxryrLrzr{rr|r6r}rr~rrrrrrirrrrrr"r"r#rsF          zAsyncBatches.deletecs$t||}|j|||dIdHS)a{Creates a batch job asynchronously. Args: model (str): The model to use for the batch job. src (str): The source of the batch job. Currently supports GCS URI(-s) or BigQuery URI. Example: "gs://path/to/input/data" or "bq://projectId.bqDatasetId.bqTableId". 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( model="gemini-2.0-flash-001", src="gs://path/to/input/data", ) rnNrrr"r"r#r3s zAsyncBatches.createcs0|dur t}td|j|j|dIdH|S)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}") Nrbrl)r rrrrr"r"r#rRszAsyncBatches.list)rrrrrr rrrrrzrrrrrrrrrrrr"r"r"r#rsp : J < 5 M  r)N)/rloggingtypingrrr urllib.parserrrrrr r r/r rwr r rrrpagersrr getLoggerloggerdictrobjectr$r*r1r:rArCrJrKrLrPrRrSr^rgri BaseModulerkrr"r"r"r#s$                  %                  ;    r