o %g @s@ddlZddlmZmZmZddlmZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lmZdd l mZdd l mZdd lmZmZedZ d5dedeeefdeedefddZ d5dedeeefdeedefddZ d5dedeeefdeedefddZ d5dedeeefdeedefddZ d5dedeeefdeedefddZ d5dedeeefdeedefddZ d5dedeeefdeedefdd Z! d5dedeeefdeedefd!d"Z" d5dedeeefdeedefd#d$Z# d5dedeeefdeedefd%d&Z$ d5dedeeefdeedefd'd(Z% d5dedeeefdeedefd)d*Z& d5dedeeefdeedefd+d,Z' d5dedeeefdeedefd-d.Z( d5dedeeefdeedefd/d0Z)Gd1d2d2ej*Z+Gd3d4d4ej*Z,dS)6N)AnyOptionalUnion) urlencode) _api_module)_common) _extra_utils) _transformers)types) BaseApiClient)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.batches api_client from_object parent_objectreturncC~i}t|dgdurt|dgt|dgt|dgdur)t|ddgt|dgt|dgdur=t|ddgt|dg|S) NformatinstancesFormatgcs_uri gcsSourceuris bigquery_uribigquerySourceinputUrigetvsetvrrr to_objectr#V/mnt/skqttb/ctump_chatbot/chatbot/lib/python3.10/site-packages/google/genai/batches.py_BatchJobSource_to_vertex"s r%cCr) NrpredictionsFormatrgcsDestinationoutputUriPrefixrbigqueryDestination outputUrirr!r#r#r$_BatchJobDestination_to_vertex8s   r+c Csdi}t|dgdurt|dgt|dgt|dgdur0t|dgt|t|t|dg||S)N display_name displayNamedest outputConfig)rr r+tt_batch_job_destinationr!r#r#r$_CreateBatchJobConfig_to_vertexRs r2c Csi}t|dgdurt|dgt|t|dgt|dgdur4t|dgt|t|t|dg|t|dgdurKt|dgt|t|dg||S)Nmodelsrc inputConfigconfig)rr r0t_modelr%t_batch_job_sourcer2r!r#r#r$#_CreateBatchJobParameters_to_vertexjs4 r9c C^i}t|dgdurt|ddgt|t|dgt|dgdur-t|dgt|dg|SNname_urlr6rr r0t_batch_job_namer!r#r#r$ _GetBatchJobParameters_to_vertexr@c Cr:r;r>r!r#r#r$#_CancelBatchJobParameters_to_vertexrArBcCsi}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 rIcCs6i}t|dgdurt|dgt|t|dg||S)Nr6)rr rIr!r#r#r$"_ListBatchJobsParameters_to_vertexsrJc Cr:r;r>r!r#r#r$#_DeleteBatchJobParameters_to_vertexrArKcCszi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur;t|dgt|dg|S)Ndetailscodemessagerr!r#r#r$_JobError_from_vertexsrOcCi}t|dgdurt|dgt|dgt|ddgdur*t|dgt|ddgt|ddgdur?t|dgt|ddg|S) Nrrrrrrrrrr!r#r#r$_BatchJobSource_from_vertexs rQcCrP) Nr&rr'r(rr)r*rrr!r#r#r$ _BatchJobDestination_from_vertexs   rRcCsi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur;t|dgt|dgt|dgdurRt|dgt|t|dg|t|dgduret|dgt|dgt|dgdurxt|d gt|dgt|d gdurt|d gt|d gt|d gdurt|d gt|d gt|dgdurt|dgt|dgt|dgdurt|dgt|t|dg|t|dgdurt|dgt|t|dg||S)Nr<r-r,stateerror createTime create_time startTime start_timeendTimeend_time updateTime update_timer3r5r4r/r.)rr rOrQrRr!r#r#r$_BatchJob_from_vertex4sTr]csdit|dgdurtdgt|dgt|dgdur0tdgfddt|dgDS)N nextPageTokennext_page_tokenbatchPredictionJobs batch_jobscsg|]}t|qSr#)r]).0itemrr"r#r$ }s z6_ListBatchJobsResponse_from_vertex..r)rrrr#rdr$"_ListBatchJobsResponse_from_vertexps   rfcCsi}t|dgdurt|dgt|dgt|dgdur(t|dgt|dgt|dgdur?t|dgt|t|dg||S)Nr<donerT)rr rOr!r#r#r$_DeleteResourceJob_from_vertexsrhc @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||| } |jjrit|j| } tjj| |d } |j| | S Nr3r4r66This method is only supported in the Vertex AI client.r=r`rD?r6postresponsekwargs)r _CreateBatchJobParameters _api_clientvertexai ValueErrorr9get format_maprpopr6 http_optionsrconvert_to_dictencode_unserializable_typesrequestr]BatchJob_from_response model_dump_verify_response selfr3r4r6parameter_model request_dictrequest_url_dictpath query_paramsr{ response_dict return_valuer#r#r$_createsD          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 |||} |jjrht|j| } 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<r6rnr=batchPredictionJobs/{name}rDror6Nrxrq)r _GetBatchJobParametersrurvrwr@rxryrrzr6r{rr|r}r~r]rrrr rr<r6rrrrrr{rrr#r#r$rxsB          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') rrnr=!batchPredictionJobs/{name}:cancelrDror6Nrp)r _CancelBatchJobParametersrurvrwrBrxryrrzr6r{rr|r}r~ rr<r6rrrrrr{rr#r#r$cancels4        zBatches.cancelc Cstj|d}|jjstdt|j|}|d}|r!d|}nd}|d}|r3|dt|}| ddd}|j durJ|j j durJ|j j }t |}t |}|jd|||}|jjrgt|j|}tjj||d } |j| | S Nrkrnr=r`rDror6rxrq)r _ListBatchJobsParametersrurvrwrJrxryrrzr6r{rr|r}r~rfListBatchJobsResponserrr rr6rrrrrr{rrr#r#r$_listWsD         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') rrnr=rrDror6Ndeleterq)r _DeleteBatchJobParametersrurvrwrKrxryrrzr6r{rr|r}r~rhDeleteResourceJobrrrrr#r#r$rsF         zBatches.deletecCst||}|j|||dS)a{Creates 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-1.5-flash", src="gs://path/to/input/data", ) print(batch_job.state) rmr 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}") Nrark)r ListBatchJobsConfigrrrr6r#r#r$lists z Batches.list)__name__ __module__ __qualname__strrr CreateBatchJobConfigOrDictrrGetBatchJobConfigOrDictrxCancelBatchJobConfigOrDictrListBatchJobsConfigOrDictrrDeleteBatchJobConfigOrDictrrrrrr#r#r#r$rjsp 8 H < 7 M !rjc @ri) AsyncBatchesNrkr3r4r6rc stj|||d}|jjstdt|j|}|d}|r$d|}nd}|d}|r6|dt|}| ddd} |j durM|j j durM|j j } t |}t |}|jd||| IdH} |jjrmt|j| } tjj| |d } |j| | Srl)r rtrurvrwr9rxryrrzr6r{rr|r} async_requestr]rrrrrr#r#r$rsF           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} |jjrlt|j| } 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}") rrnr=rrDror6Nrxrq)r rrurvrwr@rxryrrzr6r{rr|r}rr]rrrrrr#r#r$rxIsD           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') rrnr=rrDror6Nrp)r rrurvrwrBrxryrrzr6r{rr|r}rrr#r#r$rs6        zAsyncBatches.cancelc stj|d}|jjstdt|j|}|d}|r"d|}nd}|d}|r4|dt|}| ddd}|j durK|j j durK|j j }t |}t |}|jd|||IdH}|jjrkt|j|}tjj||d } |j| | Sr)r rrurvrwrJrxryrrzr6r{rr|r}rrfrrrrrr#r#r$rsF          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') rrnr=rrDror6Nrrq)r rrurvrwrKrxryrrzr6r{rr|r}rrhrrrrrr#r#r$rsH          zAsyncBatches.deletecs$t||}|j|||dIdHS)awCreates 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-1.5-flash", src="gs://path/to/input/data", ) rmNrrr#r#r$rDs 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}") Nrark)r rrrrr#r#r$rcszAsyncBatches.list)rrrrrr rrrrrxrrrrrrrrrrrr#r#r#r$rsp 8 H < 7 M  r)N)-loggingtypingrrr urllib.parserrrr r r0r rur r rrr pagersrr getLoggerloggerdictobjectr%r+r2r9r@rBrIrJrKrOrQrRr]rfrh BaseModulerjrr#r#r#r$sN                  '                  ?    t