Skip to content

Commit 47647f3

Browse files
shollymansduskis
authored andcommitted
---
yaml --- r: 33943 b: refs/heads/autosynth-scheduler c: 5f045ef h: refs/heads/master i: 33941: ab4c5ed 33939: 3206727 33935: 505f6db
1 parent 54430bb commit 47647f3

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
@@ -136,7 +136,7 @@ refs/heads/autosynth-kms: d31449d6621a50fb16a4bef4f30f0f3051d27d7c
136136
refs/heads/autosynth-language: 6130869312f99a1e7d3aa0485759172a23333cc5
137137
refs/heads/autosynth-os-login: 49028d40ac477fca5f948cc5a3ce7422729fdb67
138138
refs/heads/autosynth-redis: 2b698ebe7faaa0b93246576a88941682e0888e57
139-
refs/heads/autosynth-scheduler: 7f07a1adf7c6adaed14791fa1f059bdc7284571a
139+
refs/heads/autosynth-scheduler: 5f045ef212c60e819c6d5ba374b838036a19441b
140140
refs/heads/autosynth-spanner: de02ca32edea133b68b51052e325359a3704b5d2
141141
refs/heads/autosynth-speech: 64692f6db11364f663921be02c08072b966b6e7b
142142
refs/heads/autosynth-tasks: eb03eeab747e925175890db923945384d89b273a

branches/autosynth-scheduler/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-scheduler/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)