Skip to content
This repository was archived by the owner on Oct 31, 2023. It is now read-only.

Commit ce0077b

Browse files
chore: use gapic-generator-python 0.52.0 (#36)
- [ ] Regenerate this pull request now. fix: improper types in pagers generation PiperOrigin-RevId: 399773015 Source-Link: googleapis/googleapis@410c184 Source-Link: https://github.com/googleapis/googleapis-gen/commit/290e883545e3ac9ff2bd00cd0dacb28f1b8ca945 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMjkwZTg4MzU0NWUzYWM5ZmYyYmQwMGNkMGRhY2IyOGYxYjhjYTk0NSJ9
1 parent 59fb40d commit ce0077b

File tree

3 files changed

+26
-26
lines changed

3 files changed

+26
-26
lines changed

google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/pagers.py

+10-10
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
#
1616
from typing import (
1717
Any,
18-
AsyncIterable,
18+
AsyncIterator,
1919
Awaitable,
2020
Callable,
21-
Iterable,
2221
Sequence,
2322
Tuple,
2423
Optional,
24+
Iterator,
2525
)
2626

2727
from google.cloud.dataflow_v1beta3.types import jobs
@@ -74,14 +74,14 @@ def __getattr__(self, name: str) -> Any:
7474
return getattr(self._response, name)
7575

7676
@property
77-
def pages(self) -> Iterable[jobs.ListJobsResponse]:
77+
def pages(self) -> Iterator[jobs.ListJobsResponse]:
7878
yield self._response
7979
while self._response.next_page_token:
8080
self._request.page_token = self._response.next_page_token
8181
self._response = self._method(self._request, metadata=self._metadata)
8282
yield self._response
8383

84-
def __iter__(self) -> Iterable[jobs.Job]:
84+
def __iter__(self) -> Iterator[jobs.Job]:
8585
for page in self.pages:
8686
yield from page.jobs
8787

@@ -136,14 +136,14 @@ def __getattr__(self, name: str) -> Any:
136136
return getattr(self._response, name)
137137

138138
@property
139-
async def pages(self) -> AsyncIterable[jobs.ListJobsResponse]:
139+
async def pages(self) -> AsyncIterator[jobs.ListJobsResponse]:
140140
yield self._response
141141
while self._response.next_page_token:
142142
self._request.page_token = self._response.next_page_token
143143
self._response = await self._method(self._request, metadata=self._metadata)
144144
yield self._response
145145

146-
def __aiter__(self) -> AsyncIterable[jobs.Job]:
146+
def __aiter__(self) -> AsyncIterator[jobs.Job]:
147147
async def async_generator():
148148
async for page in self.pages:
149149
for response in page.jobs:
@@ -202,14 +202,14 @@ def __getattr__(self, name: str) -> Any:
202202
return getattr(self._response, name)
203203

204204
@property
205-
def pages(self) -> Iterable[jobs.ListJobsResponse]:
205+
def pages(self) -> Iterator[jobs.ListJobsResponse]:
206206
yield self._response
207207
while self._response.next_page_token:
208208
self._request.page_token = self._response.next_page_token
209209
self._response = self._method(self._request, metadata=self._metadata)
210210
yield self._response
211211

212-
def __iter__(self) -> Iterable[jobs.Job]:
212+
def __iter__(self) -> Iterator[jobs.Job]:
213213
for page in self.pages:
214214
yield from page.jobs
215215

@@ -264,14 +264,14 @@ def __getattr__(self, name: str) -> Any:
264264
return getattr(self._response, name)
265265

266266
@property
267-
async def pages(self) -> AsyncIterable[jobs.ListJobsResponse]:
267+
async def pages(self) -> AsyncIterator[jobs.ListJobsResponse]:
268268
yield self._response
269269
while self._response.next_page_token:
270270
self._request.page_token = self._response.next_page_token
271271
self._response = await self._method(self._request, metadata=self._metadata)
272272
yield self._response
273273

274-
def __aiter__(self) -> AsyncIterable[jobs.Job]:
274+
def __aiter__(self) -> AsyncIterator[jobs.Job]:
275275
async def async_generator():
276276
async for page in self.pages:
277277
for response in page.jobs:

google/cloud/dataflow_v1beta3/services/messages_v1_beta3/pagers.py

+6-6
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
#
1616
from typing import (
1717
Any,
18-
AsyncIterable,
18+
AsyncIterator,
1919
Awaitable,
2020
Callable,
21-
Iterable,
2221
Sequence,
2322
Tuple,
2423
Optional,
24+
Iterator,
2525
)
2626

2727
from google.cloud.dataflow_v1beta3.types import messages
@@ -74,14 +74,14 @@ def __getattr__(self, name: str) -> Any:
7474
return getattr(self._response, name)
7575

7676
@property
77-
def pages(self) -> Iterable[messages.ListJobMessagesResponse]:
77+
def pages(self) -> Iterator[messages.ListJobMessagesResponse]:
7878
yield self._response
7979
while self._response.next_page_token:
8080
self._request.page_token = self._response.next_page_token
8181
self._response = self._method(self._request, metadata=self._metadata)
8282
yield self._response
8383

84-
def __iter__(self) -> Iterable[messages.JobMessage]:
84+
def __iter__(self) -> Iterator[messages.JobMessage]:
8585
for page in self.pages:
8686
yield from page.job_messages
8787

@@ -136,14 +136,14 @@ def __getattr__(self, name: str) -> Any:
136136
return getattr(self._response, name)
137137

138138
@property
139-
async def pages(self) -> AsyncIterable[messages.ListJobMessagesResponse]:
139+
async def pages(self) -> AsyncIterator[messages.ListJobMessagesResponse]:
140140
yield self._response
141141
while self._response.next_page_token:
142142
self._request.page_token = self._response.next_page_token
143143
self._response = await self._method(self._request, metadata=self._metadata)
144144
yield self._response
145145

146-
def __aiter__(self) -> AsyncIterable[messages.JobMessage]:
146+
def __aiter__(self) -> AsyncIterator[messages.JobMessage]:
147147
async def async_generator():
148148
async for page in self.pages:
149149
for response in page.job_messages:

google/cloud/dataflow_v1beta3/services/metrics_v1_beta3/pagers.py

+10-10
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
#
1616
from typing import (
1717
Any,
18-
AsyncIterable,
18+
AsyncIterator,
1919
Awaitable,
2020
Callable,
21-
Iterable,
2221
Sequence,
2322
Tuple,
2423
Optional,
24+
Iterator,
2525
)
2626

2727
from google.cloud.dataflow_v1beta3.types import metrics
@@ -74,14 +74,14 @@ def __getattr__(self, name: str) -> Any:
7474
return getattr(self._response, name)
7575

7676
@property
77-
def pages(self) -> Iterable[metrics.JobExecutionDetails]:
77+
def pages(self) -> Iterator[metrics.JobExecutionDetails]:
7878
yield self._response
7979
while self._response.next_page_token:
8080
self._request.page_token = self._response.next_page_token
8181
self._response = self._method(self._request, metadata=self._metadata)
8282
yield self._response
8383

84-
def __iter__(self) -> Iterable[metrics.StageSummary]:
84+
def __iter__(self) -> Iterator[metrics.StageSummary]:
8585
for page in self.pages:
8686
yield from page.stages
8787

@@ -136,14 +136,14 @@ def __getattr__(self, name: str) -> Any:
136136
return getattr(self._response, name)
137137

138138
@property
139-
async def pages(self) -> AsyncIterable[metrics.JobExecutionDetails]:
139+
async def pages(self) -> AsyncIterator[metrics.JobExecutionDetails]:
140140
yield self._response
141141
while self._response.next_page_token:
142142
self._request.page_token = self._response.next_page_token
143143
self._response = await self._method(self._request, metadata=self._metadata)
144144
yield self._response
145145

146-
def __aiter__(self) -> AsyncIterable[metrics.StageSummary]:
146+
def __aiter__(self) -> AsyncIterator[metrics.StageSummary]:
147147
async def async_generator():
148148
async for page in self.pages:
149149
for response in page.stages:
@@ -202,14 +202,14 @@ def __getattr__(self, name: str) -> Any:
202202
return getattr(self._response, name)
203203

204204
@property
205-
def pages(self) -> Iterable[metrics.StageExecutionDetails]:
205+
def pages(self) -> Iterator[metrics.StageExecutionDetails]:
206206
yield self._response
207207
while self._response.next_page_token:
208208
self._request.page_token = self._response.next_page_token
209209
self._response = self._method(self._request, metadata=self._metadata)
210210
yield self._response
211211

212-
def __iter__(self) -> Iterable[metrics.WorkerDetails]:
212+
def __iter__(self) -> Iterator[metrics.WorkerDetails]:
213213
for page in self.pages:
214214
yield from page.workers
215215

@@ -264,14 +264,14 @@ def __getattr__(self, name: str) -> Any:
264264
return getattr(self._response, name)
265265

266266
@property
267-
async def pages(self) -> AsyncIterable[metrics.StageExecutionDetails]:
267+
async def pages(self) -> AsyncIterator[metrics.StageExecutionDetails]:
268268
yield self._response
269269
while self._response.next_page_token:
270270
self._request.page_token = self._response.next_page_token
271271
self._response = await self._method(self._request, metadata=self._metadata)
272272
yield self._response
273273

274-
def __aiter__(self) -> AsyncIterable[metrics.WorkerDetails]:
274+
def __aiter__(self) -> AsyncIterator[metrics.WorkerDetails]:
275275
async def async_generator():
276276
async for page in self.pages:
277277
for response in page.workers:

0 commit comments

Comments
 (0)