Fix schedule workflow action retry policy (#2082)

Fix schedule workflow action retry policy

Author: Quinn-With-Two-Ns

temporal-sdk/src/main/java/io/temporal/internal/client/ScheduleProtoUtil.java

@@ -21,6 +21,7 @@
 package io.temporal.internal.client;
 
 import static io.temporal.internal.common.HeaderUtils.toHeaderGrpc;
+import static io.temporal.internal.common.RetryOptionsUtils.toRetryPolicy;
 
 import com.google.common.base.MoreObjects;
 import com.google.common.base.Preconditions;
@@ -36,6 +37,7 @@
 import io.temporal.api.workflow.v1.NewWorkflowExecutionInfo;
 import io.temporal.client.WorkflowOptions;
 import io.temporal.client.schedules.*;
+import io.temporal.common.RetryOptions;
 import io.temporal.common.context.ContextPropagator;
 import io.temporal.common.converter.DataConverter;
 import io.temporal.common.converter.EncodedValues;
@@ -128,6 +130,11 @@ public ScheduleAction actionToProto(io.temporal.client.schedules.ScheduleAction
         workflowRequest.setInput(inputArgs.get());
       }
 
+      RetryOptions retryOptions = wfOptions.getRetryOptions();
+      if (retryOptions != null) {
+        workflowRequest.setRetryPolicy(toRetryPolicy(retryOptions));
+      }
+
       if (startWorkflowAction.getOptions().getMemo() != null) {
         Map<String, Payload> memo = new HashMap<>();
         for (Map.Entry<String, Object> item :

temporal-sdk/src/test/java/io/temporal/client/schedules/ScheduleTest.java

@@ -24,6 +24,7 @@
 
 import io.temporal.api.enums.v1.ScheduleOverlapPolicy;
 import io.temporal.client.WorkflowOptions;
+import io.temporal.common.RetryOptions;
 import io.temporal.common.converter.EncodedValues;
 import io.temporal.common.interceptors.ScheduleClientInterceptor;
 import io.temporal.testing.internal.SDKTestWorkflowRule;
@@ -301,10 +302,12 @@ public void describeSchedules() {
             .setMemo(Collections.singletonMap("memokey2", "memoval2"))
             .build();
     String scheduleId = UUID.randomUUID().toString();
+    RetryOptions retryOptions = RetryOptions.newBuilder().setMaximumAttempts(1).build();
     WorkflowOptions wfOptions =
         WorkflowOptions.newBuilder()
             .setWorkflowId("test")
             .setTaskQueue(testWorkflowRule.getTaskQueue())
+            .setRetryOptions(retryOptions)
             .setMemo(Collections.singletonMap("memokey1", "memoval1"))
             .build();
 
@@ -360,7 +363,7 @@ public void describeSchedules() {
     //
     Assert.assertEquals(scheduleId, description.getId());
     Assert.assertEquals("memoval2", description.getMemo("memokey2", String.class));
-    //
+    // Assert action
     Assert.assertEquals(
         ScheduleActionStartWorkflow.class, description.getSchedule().getAction().getClass());
     ScheduleActionStartWorkflow startWfAction =
@@ -372,6 +375,7 @@ public void describeSchedules() {
         (EncodedValues) startWfAction.getOptions().getMemo().get("memokey1");
     String memoValue = encodedMemo.get(0, String.class);
     Assert.assertEquals("memoval1", memoValue);
+    Assert.assertEquals(startWfAction.getOptions().getRetryOptions(), retryOptions);
     //
     Assert.assertEquals(
         ScheduleSpec.newBuilder(description.getSchedule().getSpec())