feat: Add CANCELLED to StreamWriter retryable error code (#1725)

yirutang · gcf-owl-bot[bot] · web-flow · commit 6d4c00474a40 · 2022-08-01T15:42:27.000-07:00
* 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>
diff --git 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
@@ -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) {

Original file line number	Diff line number	Diff line change
`@@ -635,7 +635,9 @@ private boolean isRetriableError(Throwable t) {`
`635`	`635`	`if (Errors.isRetryableInternalStatus(status)) {`
`636`	`636`	`return true;`
`637`	`637`	`}`
`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;`
`639`	`641`	`}`
`640`	`642`
`641`	`643`	`private void doneCallback(Throwable finalStatus) {`