Feature/939208 fix persistence

core/src/main/java/com/netflix/conductor/core/config/ConductorProperties.java

@@ -60,6 +60,9 @@ public class ConductorProperties {
     /** Used to enable/disable the workflow execution lock. */
     private boolean workflowExecutionLockEnabled = false;
 
+    /** Used to enable/disable the duplicate message delivery persistence. */
+    private boolean eventExecutionPersistenceEnabled = true;
+
     /** The time (in milliseconds) for which the lock is leased for. */
     private Duration lockLeaseTime = Duration.ofMillis(60000);
 
@@ -299,6 +302,14 @@ public void setWorkflowExecutionLockEnabled(boolean workflowExecutionLockEnabled
         this.workflowExecutionLockEnabled = workflowExecutionLockEnabled;
     }
 
+    public boolean isEventExecutionPersistenceEnabled() {
+        return eventExecutionPersistenceEnabled;
+    }
+
+    public void setEventExecutionPersistenceEnabled(boolean eventExecutionPersistenceEnabled) {
+        this.eventExecutionPersistenceEnabled = eventExecutionPersistenceEnabled;
+    }
+
     public Duration getLockLeaseTime() {
         return lockLeaseTime;
     }

core/src/main/java/com/netflix/conductor/service/ExecutionService.java

@@ -56,6 +56,7 @@ public class ExecutionService {
     private final TaskStatusListener taskStatusListener;
 
     private final long queueTaskMessagePostponeSecs;
+    private final boolean isEventExecutionPersistenceEnabled;
 
     private static final int MAX_POLL_TIMEOUT_MS = 5000;
     private static final int POLL_COUNT_ONE = 1;
@@ -76,6 +77,9 @@ public ExecutionService(
 
         this.queueTaskMessagePostponeSecs =
                 properties.getTaskExecutionPostponeDuration().getSeconds();
+
+        this.isEventExecutionPersistenceEnabled = properties.isEventExecutionPersistenceEnabled();
+
         this.systemTaskRegistry = systemTaskRegistry;
         this.taskStatusListener = taskStatusListener;
     }
@@ -576,15 +580,22 @@ public List<Task> getPendingTasksForTaskType(String taskType) {
     }
 
     public boolean addEventExecution(EventExecution eventExecution) {
-        return executionDAOFacade.addEventExecution(eventExecution);
+        if (isEventExecutionPersistenceEnabled) {
+            return executionDAOFacade.addEventExecution(eventExecution);
+        }
+        return true;
     }
 
     public void removeEventExecution(EventExecution eventExecution) {
-        executionDAOFacade.removeEventExecution(eventExecution);
+        if (isEventExecutionPersistenceEnabled) {
+            executionDAOFacade.removeEventExecution(eventExecution);
+        }
     }
 
     public void updateEventExecution(EventExecution eventExecution) {
-        executionDAOFacade.updateEventExecution(eventExecution);
+        if (isEventExecutionPersistenceEnabled) {
+            executionDAOFacade.updateEventExecution(eventExecution);
+        }
     }
 
     /**

server/src/main/resources/application.properties

@@ -73,6 +73,9 @@ conductor.default-event-queue.type=sqs
 conductor.app.workflow-execution-lock-enabled=false
 conductor.workflow-execution-lock.type=noop_lock
 
+#Used to enable/disable the duplicate message delivery persistence
+conductor.app.eventExecutionPersistenceEnabled=true
+
 #Redis cluster settings for locking module
 # conductor.redis-lock.serverType=single
 #Comma separated list of server nodes