Skip to content

Commit 882ec43

Browse files
shollymansduskis
authored andcommitted
---
yaml --- r: 31093 b: refs/heads/autosynth-bigquerystorage c: 5f045ef h: refs/heads/master i: 31091: 6bbe7af
1 parent 3b3527a commit 882ec43

3 files changed

Lines changed: 3 additions & 13 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
123123
refs/heads/autosynth-asset: bdb45634a0fe8f7a510692b56b31f5312e25f453
124124
refs/heads/autosynth-automl: 22f9dd5b6f5df8dbfa7da0126864d565229519b2
125125
refs/heads/autosynth-bigquerydatatransfer: 71b6b6d2a992d05999b53e6e130c4fc1c8c8b4d7
126-
refs/heads/autosynth-bigquerystorage: 7f07a1adf7c6adaed14791fa1f059bdc7284571a
126+
refs/heads/autosynth-bigquerystorage: 5f045ef212c60e819c6d5ba374b838036a19441b
127127
refs/heads/autosynth-bigtable: 9e5429f45cf9face9fed585d0233534993e36b58
128128
refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
129129
refs/heads/autosynth-containeranalysis: af5b804492292b43372c9fe00386696136ccae89

branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/stub/EnhancedBigQueryStorageStubSettingsTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ public void testCreateReadSessionSettings() {
120120
public void testReadRowsSettings() {
121121
ServerStreamingCallSettings.Builder<ReadRowsRequest, ReadRowsResponse> builder =
122122
EnhancedBigQueryStorageStubSettings.newBuilder().readRowsSettings();
123-
assertThat(builder.getRetryableCodes()).containsAllOf(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);
123+
assertThat(builder.getRetryableCodes()).contains(Code.UNAVAILABLE);
124124
RetrySettings retrySettings = builder.getRetrySettings();
125125
assertThat(retrySettings.getInitialRetryDelay()).isEqualTo(Duration.ofMillis(100L));
126126
assertThat(retrySettings.getRetryDelayMultiplier()).isWithin(1e-6).of(1.3);
@@ -157,7 +157,7 @@ public void testSplitReadStreamSettings() {
157157
}
158158

159159
private void verifyRetrySettings(Set<Code> retryCodes, RetrySettings retrySettings) {
160-
assertThat(retryCodes).containsAllOf(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);
160+
assertThat(retryCodes).contains(Code.UNAVAILABLE);
161161
assertThat(retrySettings.getTotalTimeout()).isGreaterThan(Duration.ZERO);
162162
assertThat(retrySettings.getInitialRetryDelay()).isGreaterThan(Duration.ZERO);
163163
assertThat(retrySettings.getRetryDelayMultiplier()).isAtLeast(1.0);

branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/stub/readrows/ReadRowsRetryTest.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -112,11 +112,6 @@ public void multipleRetryTestWithZeroInitialOffset() {
112112
.respondWithNumberOfRows(5)
113113
.respondWithStatus(Code.UNAVAILABLE));
114114

115-
service.expectations.add(
116-
RpcExpectation.create()
117-
.expectRequest("fake-stream", 5)
118-
.respondWithStatus(Code.DEADLINE_EXCEEDED));
119-
120115
service.expectations.add(
121116
RpcExpectation.create()
122117
.expectRequest("fake-stream", 5)
@@ -139,11 +134,6 @@ public void multipleRetryTestWithNonZeroInitialOffset() {
139134
.respondWithNumberOfRows(5)
140135
.respondWithStatus(Code.UNAVAILABLE));
141136

142-
service.expectations.add(
143-
RpcExpectation.create()
144-
.expectRequest("fake-stream", 22)
145-
.respondWithStatus(Code.DEADLINE_EXCEEDED));
146-
147137
service.expectations.add(
148138
RpcExpectation.create()
149139
.expectRequest("fake-stream", 22)

0 commit comments

Comments
 (0)