fix: Set max retry at 5 for executePipeline (#2307)

Author: wu-hui

google-cloud-firestore/src/main/java/com/google/cloud/firestore/spi/v1/GrpcFirestoreRpc.java

@@ -148,6 +148,7 @@ public GrpcFirestoreRpc(final FirestoreOptions options) throws IOException {
         firestoreBuilder.runQuerySettings().retrySettings().setMaxAttempts(5);
         firestoreBuilder.runAggregationQuerySettings().retrySettings().setMaxAttempts(5);
         firestoreBuilder.batchGetDocumentsSettings().retrySettings().setMaxAttempts(5);
+        firestoreBuilder.executePipelineSettings().retrySettings().setMaxAttempts(5);
       } else {
         firestoreBuilder.applyToAllUnaryMethods(
             builder -> {
@@ -158,6 +159,7 @@ public GrpcFirestoreRpc(final FirestoreOptions options) throws IOException {
         firestoreBuilder.runQuerySettings().setRetrySettings(retrySettings);
         firestoreBuilder.runAggregationQuerySettings().setRetrySettings(retrySettings);
         firestoreBuilder.batchGetDocumentsSettings().setRetrySettings(retrySettings);
+        firestoreBuilder.executePipelineSettings().setRetrySettings(retrySettings);
       }
 
       ApiTracerFactory apiTracerFactory = options.getApiTracerFactory();

google-cloud-firestore/src/test/java/com/google/cloud/firestore/spi/v1/GrpcFirestoreRpcTest.java

@@ -38,6 +38,8 @@
 import com.google.firestore.v1.BeginTransactionResponse;
 import com.google.firestore.v1.CommitRequest;
 import com.google.firestore.v1.CommitResponse;
+import com.google.firestore.v1.ExecutePipelineRequest;
+import com.google.firestore.v1.ExecutePipelineResponse;
 import com.google.firestore.v1.ListDocumentsRequest;
 import com.google.firestore.v1.ListDocumentsResponse;
 import com.google.firestore.v1.PartitionQueryRequest;
@@ -213,6 +215,18 @@ public void runAggregationQueryCallableFollowsServiceConfig() throws Exception {
         .containsExactlyElementsIn(expectedSettings.getRetryableCodes());
   }
 
+  @Test
+  public void executePipelineCallableFollowsServiceConfig() throws Exception {
+    GrpcFirestoreRpc grpcFirestoreRpc = new GrpcFirestoreRpc(firestoreOptionsWithoutOverride);
+    CallableRetryData actual = getRetryData(grpcFirestoreRpc.executePipelineCallable());
+    ServerStreamingCallSettings<ExecutePipelineRequest, ExecutePipelineResponse> expectedSettings =
+        defaultStubSettings.executePipelineSettings();
+    assertThat(actual.retrySettings)
+        .isEqualTo(withMaxAttempt5(expectedSettings.getRetrySettings()));
+    assertThat(actual.retryableCodes)
+        .containsExactlyElementsIn(expectedSettings.getRetryableCodes());
+  }
+
   @Test
   public void beginTransactionCallableFollowsServiceConfig() throws Exception {
     GrpcFirestoreRpc grpcFirestoreRpc = new GrpcFirestoreRpc(firestoreOptionsWithoutOverride);