From 5cd69f1a809cbd789d151d6318ec924c74249381 Mon Sep 17 00:00:00 2001 From: Alex Lich Date: Wed, 20 Feb 2019 17:35:01 -0800 Subject: [PATCH] remove duplicated code produced after fa35779916b3ce544ac728750b990e26e27a82f7 merge commit --- .../conductor/service/WorkflowBulkServiceImpl.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/core/src/main/java/com/netflix/conductor/service/WorkflowBulkServiceImpl.java b/core/src/main/java/com/netflix/conductor/service/WorkflowBulkServiceImpl.java index b8fea86c82..6b5433864b 100644 --- a/core/src/main/java/com/netflix/conductor/service/WorkflowBulkServiceImpl.java +++ b/core/src/main/java/com/netflix/conductor/service/WorkflowBulkServiceImpl.java @@ -47,10 +47,6 @@ public WorkflowBulkServiceImpl(WorkflowExecutor workflowExecutor) { @Service public BulkResponse pauseWorkflow(List workflowIds){ - for (String workflowId : workflowIds) { - workflowExecutor.pauseWorkflow(workflowId); - } - BulkResponse bulkResponse = new BulkResponse(); for (String workflowId : workflowIds) { try { @@ -74,7 +70,6 @@ public BulkResponse pauseWorkflow(List workflowIds){ public BulkResponse resumeWorkflow(List workflowIds) { BulkResponse bulkResponse = new BulkResponse(); for (String workflowId : workflowIds) { - workflowExecutor.resumeWorkflow(workflowId); try { workflowExecutor.resumeWorkflow(workflowId); bulkResponse.appendSuccessResponse(workflowId); @@ -97,7 +92,6 @@ public BulkResponse resumeWorkflow(List workflowIds) { public BulkResponse restart(List workflowIds, boolean useLatestDefinitions) { BulkResponse bulkResponse = new BulkResponse(); for (String workflowId : workflowIds) { - workflowExecutor.rewind(workflowId, useLatestDefinitions); try { workflowExecutor.rewind(workflowId, useLatestDefinitions); bulkResponse.appendSuccessResponse(workflowId); @@ -118,7 +112,6 @@ public BulkResponse restart(List workflowIds, boolean useLatestDefinitio public BulkResponse retry(List workflowIds) { BulkResponse bulkResponse = new BulkResponse(); for (String workflowId : workflowIds) { - workflowExecutor.retry(workflowId); try { workflowExecutor.retry(workflowId); bulkResponse.appendSuccessResponse(workflowId); @@ -140,7 +133,6 @@ public BulkResponse retry(List workflowIds) { public BulkResponse terminate(List workflowIds, String reason) { BulkResponse bulkResponse = new BulkResponse(); for (String workflowId : workflowIds) { - workflowExecutor.terminateWorkflow(workflowId, reason); try { workflowExecutor.terminateWorkflow(workflowId, reason); bulkResponse.appendSuccessResponse(workflowId);