From 6d4c00474a4056d72544b5a8966de6acaf0eecd3 Mon Sep 17 00:00:00 2001 From: Yiru Tang Date: Mon, 1 Aug 2022 15:42:27 -0700 Subject: [PATCH] feat: Add CANCELLED to StreamWriter retryable error code (#1725) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * 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 --- README.md | 4 ++-- .../com/google/cloud/bigquery/storage/v1/StreamWriter.java | 4 +++- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 141cb5808e..49e01fe6b5 100644 --- a/README.md +++ b/README.md @@ -56,13 +56,13 @@ implementation 'com.google.cloud:google-cloud-bigquerystorage' If you are using Gradle without BOM, add this to your dependencies: ```Groovy -implementation 'com.google.cloud:google-cloud-bigquerystorage:2.17.0' +implementation 'com.google.cloud:google-cloud-bigquerystorage:2.18.0' ``` If you are using SBT, add this to your dependencies: ```Scala -libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.17.0" +libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.18.0" ``` ## Authentication diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java index 75bfcdf3b5..57127066bb 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java @@ -635,7 +635,9 @@ private boolean isRetriableError(Throwable t) { if (Errors.isRetryableInternalStatus(status)) { return true; } - return status.getCode() == Status.Code.ABORTED || status.getCode() == Status.Code.UNAVAILABLE; + return status.getCode() == Code.ABORTED + || status.getCode() == Code.UNAVAILABLE + || status.getCode() == Code.CANCELLED; } private void doneCallback(Throwable finalStatus) {