fix: trigger reconnection on INTERNAL status error (#435)

googleapis · Apr 10, 2024 · f555322 · f555322
1 parent 0ba5b7d
commit f555322
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/src/managedwriter/stream_connection.ts b/src/managedwriter/stream_connection.ts
@@ -139,6 +139,7 @@ export class StreamConnection extends EventEmitter {
       gax.Status.ABORTED,
       gax.Status.CANCELLED,
       gax.Status.DEADLINE_EXCEEDED,
+      gax.Status.INTERNAL,
     ];
     return !!err.code && reconnectionErrorCodes.includes(err.code);
   }

diff --git a/system-test/managed_writer_client_test.ts b/system-test/managed_writer_client_test.ts
@@ -1149,6 +1149,10 @@ describe('managedwriter.WriterClient', () => {
             code: gax.Status.DEADLINE_EXCEEDED,
             msg: 'a msg',
           },
+          {
+            code: gax.Status.INTERNAL,
+            msg: 'received RST_STREAM with code',
+          },
         ].map(err => {
           const gerr = new gax.GoogleError(err.msg);
           gerr.code = err.code;