clean up.

Netflix · Sep 10, 2020 · 1d6c1a1 · 1d6c1a1
1 parent dea65cb
commit 1d6c1a1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/core/execution/WorkflowSweeper.java b/core/src/main/java/com/netflix/conductor/core/execution/WorkflowSweeper.java
@@ -123,6 +123,7 @@ public void sweep(List<String> workflowIds, WorkflowExecutor workflowExecutor, W
 					}
 
 				} catch (Exception e) {
+					queueDAO.setUnackTimeout(WorkflowExecutor.DECIDER_QUEUE, workflowId, config.getSweepFrequency() * 1000);
 					Monitors.error(className, "sweep");
 					logger.error("Error running sweep for " + workflowId, e);
 				}

diff --git a/jersey/src/main/java/com/netflix/conductor/server/resources/AdminResource.java b/jersey/src/main/java/com/netflix/conductor/server/resources/AdminResource.java
@@ -86,8 +86,8 @@ public String requeueSweep(@PathParam("workflowId") String workflowId) {
 	@ApiOperation("Verify and repair workflow consistency")
 	@Consumes({ MediaType.WILDCARD })
 	@Produces({ MediaType.TEXT_PLAIN })
-	public boolean verifyAndRepairWorkflowConsistency(@PathParam("workflowId") String workflowId) {
-		return adminService.verifyAndRepairWorkflowConsistency(workflowId);
+	public String verifyAndRepairWorkflowConsistency(@PathParam("workflowId") String workflowId) {
+		return String.valueOf(adminService.verifyAndRepairWorkflowConsistency(workflowId));
 	}
 
 }