From 4271ea0aaa98286696eb6822d0bef82a655a5811 Mon Sep 17 00:00:00 2001 From: "gcf-owl-bot[bot]" <78513119+gcf-owl-bot[bot]@users.noreply.github.com> Date: Tue, 31 May 2022 22:14:19 +0000 Subject: [PATCH] fix: fixes for dynamic routing and streaming descriptors (#274) - [ ] Regenerate this pull request now. Use gapic-generator-typescript v2.14.5. PiperOrigin-RevId: 450616838 Source-Link: https://github.com/googleapis/googleapis/commit/7a47b72791e0b84d78beca4c2b26bec42ce31572 Source-Link: https://github.com/googleapis/googleapis-gen/commit/42cc6331bae0b99f61b8e01ae15b05211716c4f9 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNDJjYzYzMzFiYWUwYjk5ZjYxYjhlMDFhZTE1YjA1MjExNzE2YzRmOSJ9 --- src/v1/big_query_read_client.ts | 3 ++- src/v1/big_query_write_client.ts | 3 ++- src/v1beta1/big_query_storage_client.ts | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/v1/big_query_read_client.ts b/src/v1/big_query_read_client.ts index a0246aef..525177ca 100644 --- a/src/v1/big_query_read_client.ts +++ b/src/v1/big_query_read_client.ts @@ -185,7 +185,8 @@ export class BigQueryReadClient { // Provide descriptors for these. this.descriptors.stream = { readRows: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1/big_query_write_client.ts b/src/v1/big_query_write_client.ts index 1cb67db7..2ab96c5d 100644 --- a/src/v1/big_query_write_client.ts +++ b/src/v1/big_query_write_client.ts @@ -188,7 +188,8 @@ export class BigQueryWriteClient { // Provide descriptors for these. this.descriptors.stream = { appendRows: new this._gaxModule.StreamDescriptor( - gax.StreamType.BIDI_STREAMING + gax.StreamType.BIDI_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1beta1/big_query_storage_client.ts b/src/v1beta1/big_query_storage_client.ts index 342ef1a6..544d6d47 100644 --- a/src/v1beta1/big_query_storage_client.ts +++ b/src/v1beta1/big_query_storage_client.ts @@ -179,7 +179,8 @@ export class BigQueryStorageClient { // Provide descriptors for these. this.descriptors.stream = { readRows: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), };