feat(common): add TaskDef.regionDurable and RerunWorkflowRequest.rerunParentDownstreamTasks flags

common/src/main/java/com/netflix/conductor/common/metadata/tasks/TaskDef.java

@@ -151,6 +151,15 @@ public enum RetryLogic {
     private SchemaDef outputSchema;
     private boolean enforceSchema;
 
+    /**
+     * When true, updates to tasks of this type are replicated region-durably in an active-active
+     * deployment: the update is committed locally and synchronously confirmed to the peer region(s)
+     * before the caller is acked (falling back to asynchronous convergence if the sync quorum is
+     * missed). Defaults to false (locally durable only).
+     */
+    @ProtoField(id = 26)
+    private boolean regionDurable;
+
     public TaskDef() {}
 
     public TaskDef(String name) {
@@ -529,6 +538,14 @@ public void setEnforceSchema(boolean enforceSchema) {
         this.enforceSchema = enforceSchema;
     }
 
+    public boolean isRegionDurable() {
+        return regionDurable;
+    }
+
+    public void setRegionDurable(boolean regionDurable) {
+        this.regionDurable = regionDurable;
+    }
+
     public long getTotalTimeoutSeconds() {
         return totalTimeoutSeconds;
     }

common/src/main/java/com/netflix/conductor/common/metadata/workflow/RerunWorkflowRequest.java

@@ -35,6 +35,14 @@ public class RerunWorkflowRequest {
     @ProtoField(id = 5)
     private String correlationId;
 
+    /**
+     * When rerunning from a task inside a sub-workflow, also re-run the downstream tasks of each
+     * ancestor workflow. Off by default: only the workflow named in the request is re-run, and
+     * already-completed tasks in its ancestors are left as they are.
+     */
+    @ProtoField(id = 6)
+    private boolean rerunParentDownstreamTasks;
+
     public String getReRunFromWorkflowId() {
         return reRunFromWorkflowId;
     }
@@ -67,6 +75,14 @@ public void setTaskInput(Map<String, Object> taskInput) {
         this.taskInput = taskInput;
     }
 
+    public boolean isRerunParentDownstreamTasks() {
+        return rerunParentDownstreamTasks;
+    }
+
+    public void setRerunParentDownstreamTasks(boolean rerunParentDownstreamTasks) {
+        this.rerunParentDownstreamTasks = rerunParentDownstreamTasks;
+    }
+
     public String getCorrelationId() {
         return correlationId;
     }

common/src/test/java/com/netflix/conductor/common/tasks/TaskDefTest.java

@@ -27,6 +27,7 @@
 import jakarta.validation.ValidatorFactory;
 
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertTrue;
 

grpc/src/main/java/com/netflix/conductor/grpc/AbstractProtoMapper.java

@@ -605,6 +605,7 @@ public RerunWorkflowRequestPb.RerunWorkflowRequest toProto(RerunWorkflowRequest
         if (from.getCorrelationId() != null) {
             to.setCorrelationId( from.getCorrelationId() );
         }
+        to.setRerunParentDownstreamTasks( from.isRerunParentDownstreamTasks() );
         return to.build();
     }
 
@@ -623,6 +624,7 @@ public RerunWorkflowRequest fromProto(RerunWorkflowRequestPb.RerunWorkflowReques
         }
         to.setTaskInput(taskInputMap);
         to.setCorrelationId( from.getCorrelationId() );
+        to.setRerunParentDownstreamTasks( from.getRerunParentDownstreamTasks() );
         return to;
     }
 
@@ -1037,6 +1039,7 @@ public TaskDefPb.TaskDef toProto(TaskDef from) {
         }
         to.setTotalTimeoutSeconds( from.getTotalTimeoutSeconds() );
         to.setTaskStatusListenerEnabled( from.isTaskStatusListenerEnabled() );
+        to.setRegionDurable( from.isRegionDurable() );
         return to.build();
     }
 
@@ -1070,6 +1073,7 @@ public TaskDef fromProto(TaskDefPb.TaskDef from) {
         to.setBaseType( from.getBaseType() );
         to.setTotalTimeoutSeconds( from.getTotalTimeoutSeconds() );
         to.setTaskStatusListenerEnabled( from.getTaskStatusListenerEnabled() );
+        to.setRegionDurable( from.getRegionDurable() );
         return to;
     }
 

grpc/src/main/proto/model/rerunworkflowrequest.proto

@@ -13,4 +13,5 @@ message RerunWorkflowRequest {
     string re_run_from_task_id = 3;
     map<string, google.protobuf.Value> task_input = 4;
     string correlation_id = 5;
+    bool rerun_parent_downstream_tasks = 6;
 }

grpc/src/main/proto/model/taskdef.proto

@@ -42,4 +42,5 @@ message TaskDef {
     string base_type = 21;
     int64 total_timeout_seconds = 22;
     bool task_status_listener_enabled = 23;
+    bool region_durable = 26;
 }