From f6dbe6209b01deb3093ceb1b3e3afe19bc4b17e7 Mon Sep 17 00:00:00 2001 From: Aravindan Ramkumar <1028385+aravindanr@users.noreply.github.com> Date: Thu, 1 Sep 2022 16:23:06 -0700 Subject: [PATCH] during skipTaskFromWorkflow, decide is performed inside a lock --- .../com/netflix/conductor/core/execution/WorkflowExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 7bb150193b..ae2d71d517 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 @@ -1619,7 +1619,7 @@ public void skipTaskFromWorkflow( taskToBeSkipped.setOutputMessage(skipTaskRequest.getTaskOutputMessage()); } executionDAOFacade.createTasks(Collections.singletonList(taskToBeSkipped)); - decide(workflow); + decide(workflow.getWorkflowId()); } public WorkflowModel getWorkflow(String workflowId, boolean includeTasks) {