Skip to content

Commit 6d4c004

Browse files
feat: Add CANCELLED to StreamWriter retryable error code (#1725)
* feat:Add CANCELLED to retryable error code * feat:Add CANCELLED to retryable error code * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent cfa6158 commit 6d4c004

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,13 +56,13 @@ implementation 'com.google.cloud:google-cloud-bigquerystorage'
5656
If you are using Gradle without BOM, add this to your dependencies:
5757

5858
```Groovy
59-
implementation 'com.google.cloud:google-cloud-bigquerystorage:2.17.0'
59+
implementation 'com.google.cloud:google-cloud-bigquerystorage:2.18.0'
6060
```
6161

6262
If you are using SBT, add this to your dependencies:
6363

6464
```Scala
65-
libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.17.0"
65+
libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.18.0"
6666
```
6767

6868
## Authentication

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -635,7 +635,9 @@ private boolean isRetriableError(Throwable t) {
635635
if (Errors.isRetryableInternalStatus(status)) {
636636
return true;
637637
}
638-
return status.getCode() == Status.Code.ABORTED || status.getCode() == Status.Code.UNAVAILABLE;
638+
return status.getCode() == Code.ABORTED
639+
|| status.getCode() == Code.UNAVAILABLE
640+
|| status.getCode() == Code.CANCELLED;
639641
}
640642

641643
private void doneCallback(Throwable finalStatus) {

0 commit comments

Comments
 (0)