add removeWorkflowWithExpiry back to ExecutionDAOFacade (#3150)

Netflix · Aug 5, 2022 · d7dd2e9 · d7dd2e9
1 parent ab14727
commit d7dd2e9
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/core/dal/ExecutionDAOFacade.java b/core/src/main/java/com/netflix/conductor/core/dal/ExecutionDAOFacade.java
@@ -375,6 +375,20 @@ private void removeWorkflowIndex(WorkflowModel workflow, boolean archiveWorkflow
         }
     }
 
+    public void removeWorkflowWithExpiry(
+            String workflowId, boolean archiveWorkflow, int ttlSeconds) {
+        try {
+            WorkflowModel workflow = getWorkflowModelFromDataStore(workflowId, true);
+
+            removeWorkflowIndex(workflow, archiveWorkflow);
+            // remove workflow from DAO with TTL
+            executionDAO.removeWorkflowWithExpiry(workflowId, ttlSeconds);
+        } catch (Exception e) {
+            Monitors.recordDaoError("executionDao", "removeWorkflow");
+            throw new TransientException("Error removing workflow: " + workflowId, e);
+        }
+    }
+
     /**
      * Reset the workflow state by removing from the {@link ExecutionDAO} and removing this workflow
      * from the {@link IndexDAO}.