`idZddlZddlmZmZmZmZmZmZm Z m Z e dZ e dZ Gddee Z Gdd e e ZGd d e e Zy) zPagers for the GenAI List APIs.N)Any AsyncIterator AwaitableCallableGenericIteratorLiteralTypeVarT) batch_jobsmodels tuning_jobsfilescached_contentsceZdZdZdededefdedefdZdededefdedefdZe d e e fd Z e d efd Z e d efd Ze d eeeffd Zd efdZded e fdZded dfdZy) _BasePagerz9Base pager class for iterating through paginated results.namerequest.responseconfigcX||_||_t||jxsg|_d|_|si}n1t |t rtj|}n t |}t|d|d<||_ |jdt|j|_ y)Nrnext_page_token page_token page_size) _name_requestgetattr_page_idx isinstancedictcopydeepcopy_configgetlen _page_size)selfrrrrrequest_configs X/var/www/html/ts-aiml.yecor.com/venv/lib/python3.12/site-packages/google/genai/pagers.py _init_pagez_BasePager._init_page!sDJDM4::.4"DJDI n FD !}}V,nF|n#*85F#GN< !DL$((c$**oFDOc,|j||||yN)r+)r(rrrrs r*__init__z_BasePager.__init__9s OOD'8V4r,returnc|jS)a`Returns a subset of the entire list of items. For the number of items returned, see `pageSize()`. Usage: .. code-block:: python batch_jobs_pager = client.batches.list(config={'page_size': 5}) print(f"first page: {batch_jobs_pager.page}") # first page: [BatchJob(name='projects/./locations/./batchPredictionJobs/1 )rr(s r*pagez_BasePager.pageBs ::r,c|jS)zReturns the type of paged item (for example, ``batch_jobs``). Usage: .. code-block:: python batch_jobs_pager = client.batches.list(config={'page_size': 5}) print(f"name: {batch_jobs_pager.name}") # name: batch_jobs )rr2s r*rz_BasePager.nameSs ::r,c|jS)aReturns the maximum number of items fetched by the pager at one time. Usage: .. code-block:: python batch_jobs_pager = client.batches.list(config={'page_size': 5}) print(f"page_size: {batch_jobs_pager.page_size}") # page_size: 5 )r'r2s r*rz_BasePager.page_sizebs ??r,c|jS)a Returns the configuration when making the API request for the next page. A configuration is a set of optional parameters and arguments that can be used to customize the API request. For example, the ``page_token`` parameter contains the token to request the next page. Usage: .. code-block:: python batch_jobs_pager = client.batches.list(config={'page_size': 5}) print(f"config: {batch_jobs_pager.config}") # config: {'page_size': 5, 'page_token': 'AMEw9yO5jnsGnZJLHSKDFHJJu'} )r$r2s r*rz_BasePager.configqs" <<r,c,t|jS)z6Returns the total number of items in the current page.)r&r3r2s r*__len__z_BasePager.__len__s tyy>r,indexc |j|S)z$Returns the item at the given index.)r3)r(r9s r* __getitem__z_BasePager.__getitem__s 99U r,Nch|j|j|j||jy)zInitializes the next page from the response. This is an internal method that should be called by subclasses after fetching the next page. Args: response: The response object from the API request. N)r+rrrr(rs r*_init_next_pagez_BasePager._init_next_pages" OODIIt}}h Dr,)__name__ __module__ __qualname____doc__ PagedItemrrr+r/propertylistr r3rintrr!strrr8r;r>r,r*rrsAG GS!G G  G05 5S!5 5  5 DG    I         d38n $ssq Ec Ed Er,rc@eZdZdZdefdZdeefdZdeefdZ y)Pagerz4Pager class for iterating through paginated results.r0c|jt|k\r |j|j |j}|xjdz c_|S#t$rtwxYw)zReturns the next item.)rr& next_page IndexError StopIterationr3r(items r*__next__zPager.__next__s^ yyCI  99TYY DIINI K s AA*cd|_|S)z#Returns an iterator over the items.rrr2s r*__iter__zPager.__iter__DI Kr,c|jjds td|j|j}|j ||j S)aFetches the next page of items. This makes a new API request. Usage: .. code-block:: python batch_jobs_pager = client.batches.list(config={'page_size': 5}) print(f"current page: {batch_jobs_pager.page}") batch_jobs_pager.next_page() print(f"next page: {batch_jobs_pager.page}") # current page: [BatchJob(name='projects/.../batchPredictionJobs/1 # next page: [BatchJob(name='projects/.../batchPredictionJobs/6 rNo more pages to fetch.rrr%rNrr>r3r=s r*rMzPager.next_pagesL ;;??< ( 0 11}}DKK}0H" 99r,N) r?r@rArBr rRrrUrErMrHr,r*rJrJs1<    ar,rJcteZdZdZdededeefdedeffd Zde e fd Z de fd Z de e fd ZxZS) AsyncPagerz9AsyncPager class for iterating through paginated results.rr.rrc*t|||||yr.)superr/)r(rrrr __class__s r*r/zAsyncPager.__init__s GT7Hf5r,r0cd|_|S)z)Returns an async iterator over the items.rrTr2s r* __aiter__zAsyncPager.__aiter__rVr,cK|jt|k\r |jd{|j |j}|xjdz c_|S74#t$rtwxYww)z%Returns the next item asynchronously.NrL)rr&rMrNStopAsyncIterationr3rPs r* __anext__zAsyncPager.__anext__sj yyCI!nn 99TYY DIINI K  !  !s+A9A&A$A&0A9$A&&A66A9cK|jjds td|j|jd{}|j ||j S7!w)aSFetches the next page of items asynchronously. This makes a new API request. Returns: The next page of items. Raises: IndexError: No more pages to fetch. Usage: .. code-block:: python batch_jobs_pager = await client.aio.batches.list(config={'page_size': 5}) print(f"current page: {batch_jobs_pager.page}") await batch_jobs_pager.next_page() print(f"next page: {batch_jobs_pager.page}") # current page: [BatchJob(name='projects/.../batchPredictionJobs/1 # next page: [BatchJob(name='projects/.../batchPredictionJobs/6 rrXrYNrZr=s r*rMzAsyncPager.next_pagesX. ;;??< ( 0 11]]$++]66H" 997sAA,A* "A,)r?r@rArBrCrrrr/rr rardrErM __classcell__)r_s@r*r\r\slA6 6Ys^+,6 6  6q) q tAwr,r\)rBr"typingrrrrrrr r r rCrrJr\rHr,r*rhsd & ^^^ CL E  wEwEt(JqM(V9A9r,