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 06d884636a..27508a3a56 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 @@ -514,6 +514,7 @@ public void restart(String workflowId, boolean useLatestDefinitions) { "Unable to find latest definition for %s", workflowId)); workflow.setWorkflowDefinition(workflowDef); + workflowDef = metadataMapperService.populateTaskDefinitions(workflowDef); } else { workflowDef = Optional.ofNullable(workflow.getWorkflowDefinition())