public void verifyAndRepairWorkflowTasks(String workflowId) {
        WorkflowModel workflow =
                Optional.ofNullable(executionDAO.getWorkflow(workflowId, true))
                        .orElseThrow(
                                () ->
                                        new NotFoundException(
                                                "Could not find workflow: " + workflowId));
        verifyAndRepairWorkflowTasks(workflow);
    }
Verify and repair tasks in a workflow.
core/src/main/java/com/netflix/conductor/core/reconciliation/WorkflowRepairService.java