From 363196550f5d5a7381ec88e3404d334475fe430e Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Mon, 10 Feb 2020 08:04:16 -0800 Subject: [PATCH] feat: re-generated to pick up changes in the API or client library generator. (#70) --- .../storage/v1/BaseBigQueryReadSettings.java | 8 +- .../v1/stub/BigQueryReadStubSettings.java | 8 +- .../v1alpha2/BigQueryWriteSettings.java | 8 +- .../stub/BigQueryWriteStubSettings.java | 8 +- .../v1beta1/BaseBigQueryStorageSettings.java | 8 +- .../stub/BigQueryStorageStubSettings.java | 8 +- .../v1beta2/BaseBigQueryReadSettings.java | 8 +- .../stub/BigQueryReadStubSettings.java | 8 +- .../v1/BaseBigQueryReadClientTest.java | 37 ++++ .../v1alpha2/BigQueryWriteClientTest.java | 168 ++++++++++++++++++ .../v1beta2/BaseBigQueryReadClientTest.java | 37 ++++ synth.metadata | 23 +-- 12 files changed, 302 insertions(+), 27 deletions(-) diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java index ed0e08871f..7dfff71a93 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java @@ -53,8 +53,12 @@ * * BaseBigQueryReadSettings.Builder baseBigQueryReadSettingsBuilder = * BaseBigQueryReadSettings.newBuilder(); - * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryReadSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BaseBigQueryReadSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java index 3040cae377..aea64050a2 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java @@ -68,8 +68,12 @@ * * BigQueryReadStubSettings.Builder baseBigQueryReadSettingsBuilder = * BigQueryReadStubSettings.newBuilder(); - * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryReadSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BigQueryReadStubSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java index a4153630eb..d7e3ff0522 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java @@ -62,8 +62,12 @@ * * BigQueryWriteSettings.Builder bigQueryWriteSettingsBuilder = * BigQueryWriteSettings.newBuilder(); - * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * bigQueryWriteSettingsBuilder + * .createWriteStreamSettings() + * .setRetrySettings( + * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BigQueryWriteSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java index 82c6335731..7dba9c85fa 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java @@ -71,8 +71,12 @@ * * BigQueryWriteStubSettings.Builder bigQueryWriteSettingsBuilder = * BigQueryWriteStubSettings.newBuilder(); - * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * bigQueryWriteSettingsBuilder + * .createWriteStreamSettings() + * .setRetrySettings( + * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BigQueryWriteStubSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java index 882092d9a0..a1bb6b456e 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java @@ -63,8 +63,12 @@ * * BaseBigQueryStorageSettings.Builder baseBigQueryStorageSettingsBuilder = * BaseBigQueryStorageSettings.newBuilder(); - * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryStorageSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BaseBigQueryStorageSettings baseBigQueryStorageSettings = baseBigQueryStorageSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java index 0b19a7c0cf..3ce39e32fe 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java @@ -72,8 +72,12 @@ * * BigQueryStorageStubSettings.Builder baseBigQueryStorageSettingsBuilder = * BigQueryStorageStubSettings.newBuilder(); - * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryStorageSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BigQueryStorageStubSettings baseBigQueryStorageSettings = baseBigQueryStorageSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java index 8276d74000..6570a55fc8 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java @@ -53,8 +53,12 @@ * * BaseBigQueryReadSettings.Builder baseBigQueryReadSettingsBuilder = * BaseBigQueryReadSettings.newBuilder(); - * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryReadSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BaseBigQueryReadSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java index 77c5f0e133..4d51ccb6d7 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java @@ -68,8 +68,12 @@ * * BigQueryReadStubSettings.Builder baseBigQueryReadSettingsBuilder = * BigQueryReadStubSettings.newBuilder(); - * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * baseBigQueryReadSettingsBuilder + * .createReadSessionSettings() + * .setRetrySettings( + * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * BigQueryReadStubSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build(); * * diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java index 71160a8ae1..9d26c04ab2 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java @@ -163,4 +163,41 @@ public void readRowsExceptionTest() throws Exception { Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); } } + + @Test + @SuppressWarnings("all") + public void splitReadStreamTest() { + SplitReadStreamResponse expectedResponse = SplitReadStreamResponse.newBuilder().build(); + mockBigQueryRead.addResponse(expectedResponse); + + SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build(); + + SplitReadStreamResponse actualResponse = client.splitReadStream(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryRead.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + SplitReadStreamRequest actualRequest = (SplitReadStreamRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void splitReadStreamExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryRead.addException(exception); + + try { + SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build(); + + client.splitReadStream(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } } diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java index 1709d4642a..661d422e74 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java @@ -16,16 +16,26 @@ package com.google.cloud.bigquery.storage.v1alpha2; import com.google.api.gax.core.NoCredentialsProvider; +import com.google.api.gax.grpc.GaxGrpcProperties; import com.google.api.gax.grpc.testing.LocalChannelProvider; import com.google.api.gax.grpc.testing.MockGrpcService; import com.google.api.gax.grpc.testing.MockServiceHelper; import com.google.api.gax.grpc.testing.MockStreamObserver; +import com.google.api.gax.rpc.ApiClientHeaderProvider; import com.google.api.gax.rpc.ApiStreamObserver; import com.google.api.gax.rpc.BidiStreamingCallable; import com.google.api.gax.rpc.InvalidArgumentException; import com.google.api.gax.rpc.StatusCode; import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsRequest; import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsResponse; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.BatchCommitWriteStreamsRequest; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.BatchCommitWriteStreamsResponse; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.CreateWriteStreamRequest; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.FinalizeWriteStreamRequest; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.FinalizeWriteStreamResponse; +import com.google.cloud.bigquery.storage.v1alpha2.Storage.GetWriteStreamRequest; +import com.google.cloud.bigquery.storage.v1alpha2.Stream.WriteStream; +import com.google.protobuf.AbstractMessage; import io.grpc.Status; import io.grpc.StatusRuntimeException; import java.io.IOException; @@ -78,6 +88,46 @@ public void tearDown() throws Exception { client.close(); } + @Test + @SuppressWarnings("all") + public void createWriteStreamTest() { + String name = "name3373707"; + String externalId = "externalId-1153075697"; + WriteStream expectedResponse = + WriteStream.newBuilder().setName(name).setExternalId(externalId).build(); + mockBigQueryWrite.addResponse(expectedResponse); + + CreateWriteStreamRequest request = CreateWriteStreamRequest.newBuilder().build(); + + WriteStream actualResponse = client.createWriteStream(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryWrite.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + CreateWriteStreamRequest actualRequest = (CreateWriteStreamRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void createWriteStreamExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryWrite.addException(exception); + + try { + CreateWriteStreamRequest request = CreateWriteStreamRequest.newBuilder().build(); + + client.createWriteStream(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + @Test @SuppressWarnings("all") public void appendRowsTest() throws Exception { @@ -126,4 +176,122 @@ public void appendRowsExceptionTest() throws Exception { Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); } } + + @Test + @SuppressWarnings("all") + public void getWriteStreamTest() { + String name = "name3373707"; + String externalId = "externalId-1153075697"; + WriteStream expectedResponse = + WriteStream.newBuilder().setName(name).setExternalId(externalId).build(); + mockBigQueryWrite.addResponse(expectedResponse); + + GetWriteStreamRequest request = GetWriteStreamRequest.newBuilder().build(); + + WriteStream actualResponse = client.getWriteStream(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryWrite.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + GetWriteStreamRequest actualRequest = (GetWriteStreamRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void getWriteStreamExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryWrite.addException(exception); + + try { + GetWriteStreamRequest request = GetWriteStreamRequest.newBuilder().build(); + + client.getWriteStream(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void finalizeWriteStreamTest() { + long rowCount = 1340416618L; + FinalizeWriteStreamResponse expectedResponse = + FinalizeWriteStreamResponse.newBuilder().setRowCount(rowCount).build(); + mockBigQueryWrite.addResponse(expectedResponse); + + FinalizeWriteStreamRequest request = FinalizeWriteStreamRequest.newBuilder().build(); + + FinalizeWriteStreamResponse actualResponse = client.finalizeWriteStream(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryWrite.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + FinalizeWriteStreamRequest actualRequest = (FinalizeWriteStreamRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void finalizeWriteStreamExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryWrite.addException(exception); + + try { + FinalizeWriteStreamRequest request = FinalizeWriteStreamRequest.newBuilder().build(); + + client.finalizeWriteStream(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void batchCommitWriteStreamsTest() { + BatchCommitWriteStreamsResponse expectedResponse = + BatchCommitWriteStreamsResponse.newBuilder().build(); + mockBigQueryWrite.addResponse(expectedResponse); + + BatchCommitWriteStreamsRequest request = BatchCommitWriteStreamsRequest.newBuilder().build(); + + BatchCommitWriteStreamsResponse actualResponse = client.batchCommitWriteStreams(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryWrite.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + BatchCommitWriteStreamsRequest actualRequest = + (BatchCommitWriteStreamsRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void batchCommitWriteStreamsExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryWrite.addException(exception); + + try { + BatchCommitWriteStreamsRequest request = BatchCommitWriteStreamsRequest.newBuilder().build(); + + client.batchCommitWriteStreams(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } } diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java index cd7261d48b..1b9363462f 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java @@ -163,4 +163,41 @@ public void readRowsExceptionTest() throws Exception { Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); } } + + @Test + @SuppressWarnings("all") + public void splitReadStreamTest() { + SplitReadStreamResponse expectedResponse = SplitReadStreamResponse.newBuilder().build(); + mockBigQueryRead.addResponse(expectedResponse); + + SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build(); + + SplitReadStreamResponse actualResponse = client.splitReadStream(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockBigQueryRead.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + SplitReadStreamRequest actualRequest = (SplitReadStreamRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void splitReadStreamExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockBigQueryRead.addException(exception); + + try { + SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build(); + + client.splitReadStream(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } } diff --git a/synth.metadata b/synth.metadata index d68616923f..51bf6d5e26 100644 --- a/synth.metadata +++ b/synth.metadata @@ -1,43 +1,44 @@ { - "updateTime": "2020-02-06T19:14:00.130766Z", + "updateTime": "2020-02-08T09:41:28.852134Z", "sources": [ { "generator": { "name": "artman", - "version": "0.44.4", - "dockerImage": "googleapis/artman@sha256:19e945954fc960a4bdfee6cb34695898ab21a8cf0bac063ee39b91f00a1faec8" + "version": "0.45.0", + "dockerImage": "googleapis/artman@sha256:6aec9c34db0e4be221cdaf6faba27bdc07cfea846808b3d3b964dfce3a9a0f9b" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "4cdfe8278cb6f308106580d70648001c9146e759", - "internalRef": "293614782" + "sha": "e7d8a694f4559201e6913f6610069cb08b39274e", + "internalRef": "293903652" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "4cdfe8278cb6f308106580d70648001c9146e759", - "internalRef": "293614782" + "sha": "e7d8a694f4559201e6913f6610069cb08b39274e", + "internalRef": "293903652" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "4cdfe8278cb6f308106580d70648001c9146e759", - "internalRef": "293614782" + "sha": "e7d8a694f4559201e6913f6610069cb08b39274e", + "internalRef": "293903652" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "4cdfe8278cb6f308106580d70648001c9146e759", - "internalRef": "293614782" + "sha": "e7d8a694f4559201e6913f6610069cb08b39274e", + "internalRef": "293903652", + "log": "e7d8a694f4559201e6913f6610069cb08b39274e\nDepend on the latest gapic-generator and resource names plugin.\n\nThis fixes the very old an very annoying bug: https://github.com/googleapis/gapic-generator/pull/3087\n\nPiperOrigin-RevId: 293903652\n\n806b2854a966d55374ee26bb0cef4e30eda17b58\nfix: correct capitalization of Ruby namespaces in SecurityCenter V1p1beta1\n\nPiperOrigin-RevId: 293903613\n\n1b83c92462b14d67a7644e2980f723112472e03a\nPublish annotations and grpc service config for Logging API.\n\nPiperOrigin-RevId: 293893514\n\ne46f761cd6ec15a9e3d5ed4ff321a4bcba8e8585\nGenerate the Bazel build file for recommendengine public api\n\nPiperOrigin-RevId: 293710856\n\n68477017c4173c98addac0373950c6aa9d7b375f\nMake `language_code` optional for UpdateIntentRequest and BatchUpdateIntentsRequest.\n\nThe comments and proto annotations describe this parameter as optional.\n\nPiperOrigin-RevId: 293703548\n\n16f823f578bca4e845a19b88bb9bc5870ea71ab2\nAdd BUILD.bazel files for managedidentities API\n\nPiperOrigin-RevId: 293698246\n\n2f53fd8178c9a9de4ad10fae8dd17a7ba36133f2\nAdd v1p1beta1 config file\n\nPiperOrigin-RevId: 293696729\n\n052b274138fce2be80f97b6dcb83ab343c7c8812\nAdd source field for user event and add field behavior annotations\n\nPiperOrigin-RevId: 293693115\n\n1e89732b2d69151b1b3418fff3d4cc0434f0dded\ndatacatalog: v1beta1 add three new RPCs to gapic v1beta1 config\n\nPiperOrigin-RevId: 293692823\n\n9c8bd09bbdc7c4160a44f1fbab279b73cd7a2337\nchange the name of AccessApproval service to AccessApprovalAdmin\n\nPiperOrigin-RevId: 293690934\n\n2e23b8fbc45f5d9e200572ca662fe1271bcd6760\nAdd ListEntryGroups method, add http bindings to support entry group tagging, and update some comments.\n\nPiperOrigin-RevId: 293666452\n\n0275e38a4ca03a13d3f47a9613aac8c8b0d3f1f2\nAdd proto_package field to managedidentities API. It is needed for APIs that still depend on artman generation.\n\nPiperOrigin-RevId: 293643323\n\n" } }, {