Skip to content

Commit b95fb00

Browse files
Fixed imports
1 parent 065dbf6 commit b95fb00

File tree

2 files changed

+15
-7
lines changed

2 files changed

+15
-7
lines changed

tpu/src/main/java/tpu/ListQueuedResources.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,9 @@
1818

1919
//[START tpu_queued_resources_list]
2020
import com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest;
21+
import com.google.cloud.tpu.v2alpha1.QueuedResource;
2122
import com.google.cloud.tpu.v2alpha1.TpuClient;
23+
import com.google.cloud.tpu.v2alpha1.TpuClient.ListQueuedResourcesPage;
2224
import java.io.IOException;
2325

2426
public class ListQueuedResources {
@@ -33,16 +35,20 @@ public static void main(String[] args) throws IOException {
3335
}
3436

3537
// List Queued Resources.
36-
public static TpuClient.ListQueuedResourcesPage listQueuedResources(
38+
public static ListQueuedResourcesPage listQueuedResources(
3739
String projectId, String zone) throws IOException {
3840
String parent = String.format("projects/%s/locations/%s", projectId, zone);
3941
// Initialize client that will be used to send requests. This client only needs to be created
4042
// once, and can be reused for multiple requests.
4143
try (TpuClient tpuClient = TpuClient.create()) {
4244
ListQueuedResourcesRequest request =
4345
ListQueuedResourcesRequest.newBuilder().setParent(parent).build();
46+
ListQueuedResourcesPage response = tpuClient.listQueuedResources(request).getPage();
4447

45-
return tpuClient.listQueuedResources(request).getPage();
48+
for (QueuedResource queuedResource : response.iterateAll()) {
49+
System.out.println(queuedResource.getName());
50+
}
51+
return response;
4652
}
4753
}
4854
}

tpu/src/test/java/tpu/QueuedResourceIT.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,8 @@
3333
import com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest;
3434
import com.google.cloud.tpu.v2alpha1.QueuedResource;
3535
import com.google.cloud.tpu.v2alpha1.TpuClient;
36+
import com.google.cloud.tpu.v2alpha1.TpuClient.ListQueuedResourcesPage;
37+
import com.google.cloud.tpu.v2alpha1.TpuClient.ListQueuedResourcesPagedResponse;
3638
import com.google.cloud.tpu.v2alpha1.TpuSettings;
3739
import java.io.IOException;
3840
import java.util.Arrays;
@@ -134,16 +136,16 @@ public void testListTpuVm() throws IOException {
134136

135137
TpuClient mockClient = mock(TpuClient.class);
136138
mockedTpuClient.when(TpuClient::create).thenReturn(mockClient);
137-
TpuClient.ListQueuedResourcesPagedResponse mockListQueuedResourcesResponse =
138-
mock(TpuClient.ListQueuedResourcesPagedResponse.class);
139+
ListQueuedResourcesPagedResponse mockListQueuedResourcesResponse =
140+
mock(ListQueuedResourcesPagedResponse.class);
139141
when(mockClient.listQueuedResources(any(ListQueuedResourcesRequest.class)))
140142
.thenReturn(mockListQueuedResourcesResponse);
141-
TpuClient.ListQueuedResourcesPage mockQueuedResourcesPage =
142-
mock(TpuClient.ListQueuedResourcesPage.class);
143+
ListQueuedResourcesPage mockQueuedResourcesPage =
144+
mock(ListQueuedResourcesPage.class);
143145
when(mockListQueuedResourcesResponse.getPage()).thenReturn(mockQueuedResourcesPage);
144146
when(mockQueuedResourcesPage.getValues()).thenReturn(mockListQueuedResources);
145147

146-
TpuClient.ListQueuedResourcesPage returnedList =
148+
ListQueuedResourcesPage returnedList =
147149
ListQueuedResources.listQueuedResources(PROJECT_ID, ZONE);
148150

149151
assertThat(returnedList.getValues()).isEqualTo(mockListQueuedResources);

0 commit comments

Comments
 (0)