[ThdZddlZddlmZmZmZmZmZmZm Z m Z m Z ddl m Z ddl mZe dZe dZGd d eeZGd d eeZGd deeZy)zPagers for the GenAI List APIs.N) Any AsyncIterator AwaitableCallableGenericIteratorLiteralTypeVarUnion)_common)typesT) batch_jobsmodels tuning_jobsfilescached_contentsc *eZdZdZdededefdededdf d Zdededefdedefd Ze de e fd Z e defd Z e defd Ze deej$dffdZe dej*fdZdefdZdede fdZdeddfdZy) _BasePagerz9Base pager class for iterating through paginated results.namerequest.responseconfigreturnNc|||_||_t||jxsg|_d|_t|dd|_|si}n1t |trtj|}n t|}t|d|d<||_ |jdt|j|_ y)Nrsdk_http_responsenext_page_token page_token page_size)_name_requestgetattr_page_idx_sdk_http_response isinstancedictcopydeepcopy_configgetlen _page_size)selfrrrrrequest_configs X/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/google/genai/pagers.py _init_pagez_BasePager._init_page#sDJDM4::.4"DJDI%h0CTJD n FD !}}V,nF|n#*85F#GN< !DL)--k3tzz?KDOc,|j||||yN)r2)r/rrrrs r1__init__z_BasePager.__init__=s OOD'8V4r3c|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 )r$r/s r1pagez_BasePager.pageFs ::r3c|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 )r!r8s r1rz_BasePager.nameWs ::r3c|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.r8s r1r z_BasePager.page_sizefs ??r3c|jS)z.Returns the http response of the API response.)r&r8s r1rz_BasePager.sdk_http_responseus  " ""r3c|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+r8s r1rz_BasePager.config{s" <<r3c,t|jS)z6Returns the total number of items in the current page.)r-r9r8s r1__len__z_BasePager.__len__s tyy>r3indexc |j|S)z$Returns the item at the given index.)r9)r/r@s r1 __getitem__z_BasePager.__getitem__s 99U r3ch|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)r2rr"rr/rs r1_init_next_pagez_BasePager._init_next_pages" OODIIt}}h Dr3)__name__ __module__ __qualname____doc__ PagedItemrrr2r6propertylistrr9rintr r r HttpResponserr StringDictrr?rBrEr3r1rr sSAL LS!L L  L  L45 5S!5 5  5 DG    I         #u'9'94'?!@# #  g(( $ssq Ec Ed Er3rc@eZdZdZdefdZdeefdZdeefdZ y)Pagerz4Pager class for iterating through paginated results.rc|jt|k\r |j|j |j}|xjdz c_|S#t$rtwxYw)zReturns the next item.r )r%r- next_page IndexError StopIterationr9r/items r1__next__zPager.__next__s^ yyCI  99TYY DIINI K s AA*cd|_|S)z#Returns an iterator over the items.rr%r8s r1__iter__zPager.__iter__DI Kr3c|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,rUr"rEr9rDs r1rTzPager.next_pagesL ;;??< ( 0 11}}DKK}0H" 99r3N) rFrGrHrIrrYrr\rLrTrPr3r1rRrRs1<    ar3rRcteZdZdZdededeefdedeffd Zde e fd Z de fd Z de e fd ZxZS) AsyncPagerz9AsyncPager class for iterating through paginated results.rr.rrc*t|||||yr5)superr6)r/rrrr __class__s r1r6zAsyncPager.__init__s GT7Hf5r3rcd|_|S)z)Returns an async iterator over the items.rr[r8s r1 __aiter__zAsyncPager.__aiter__r]r3cK|jt|k\r |jd{|j |j}|xjdz c_|S74#t$rtwxYww)z%Returns the next item asynchronously.Nr )r%r-rTrUStopAsyncIterationr9rWs r1 __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 rr_r`NrarDs r1rTzAsyncPager.next_pagesX. ;;??< ( 0 11]]$++]66H" 997sAA,A* "A,)rFrGrHrIrJrrrr6rrrhrkrLrT __classcell__)rfs@r1rcrcslA6 6Ys^+,6 6  6q) q tAwr3rc)rIr)typingrrrrrrr r r r rrrJrrRrcrPr3r1rpsj & fff CL E  EED(JqM(V9A9r3