diff --git a/common/src/main/java/com/netflix/conductor/common/metadata/workflow/SubWorkflowParams.java b/common/src/main/java/com/netflix/conductor/common/metadata/workflow/SubWorkflowParams.java index 1006b37687..8c18156d7e 100644 --- a/common/src/main/java/com/netflix/conductor/common/metadata/workflow/SubWorkflowParams.java +++ b/common/src/main/java/com/netflix/conductor/common/metadata/workflow/SubWorkflowParams.java @@ -41,6 +41,26 @@ public class SubWorkflowParams { @ProtoField(id = 4) private Object workflowDefinition; + private String idempotencyKey; + + private IdempotencyStrategy idempotencyStrategy; + + public String getIdempotencyKey() { + return idempotencyKey; + } + + public void setIdempotencyKey(String idempotencyKey) { + this.idempotencyKey = idempotencyKey; + } + + public IdempotencyStrategy getIdempotencyStrategy() { + return idempotencyStrategy; + } + + public void setIdempotencyStrategy(IdempotencyStrategy idempotencyStrategy) { + this.idempotencyStrategy = idempotencyStrategy; + } + /** * @return the name */ diff --git a/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java b/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java index 8e090f453f..16d7668e56 100644 --- a/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java +++ b/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java @@ -2155,4 +2155,37 @@ public WorkflowModel jumpWorkflowExecutionToTask( public void upgradeRunningWorkflowToVersion( String workflowId, UpgradeWorkflowRequest upgradeWorkflowRequest) {} + + public String startWorkflow( + String name, + Integer version, + Map workflowInput, + String externalInputPayloadStoragePath, + String correlationId, + Integer priority, + String parentWorkflowId, + String parentWorkflowTaskId, + String event, + Map taskToDomain, + String createdBy, + String idempotencyKey, + IdempotencyStrategy idempotencyStrategy) { + return null; + } + + public String startWorkflow( + WorkflowDef workflowDefinition, + Map workflowInput, + String externalInputPayloadStoragePath, + String correlationId, + Integer priority, + String parentWorkflowId, + String parentWorkflowTaskId, + String event, + Map taskToDomain, + String createdBy, + String idempotencyKey, + IdempotencyStrategy idempotencyStrategy) { + return null; + } }