Enable the indexing of tasks to be enabled / disabled

conductor-oss · Mar 1, 2024 · f5d7d1a · f5d7d1a
1 parent 39b4d31
commit f5d7d1a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/core/src/main/java/com/netflix/conductor/core/config/ConductorProperties.java b/core/src/main/java/com/netflix/conductor/core/config/ConductorProperties.java
@@ -81,6 +81,9 @@ public class ConductorProperties {
     @DurationUnit(ChronoUnit.SECONDS)
     private Duration taskExecutionPostponeDuration = Duration.ofSeconds(60);
 
+    /** Used to enable/disable the indexing of tasks. */
+    private boolean taskIndexingEnabled = true;
+
     /** Used to enable/disable the indexing of task execution logs. */
     private boolean taskExecLogIndexingEnabled = true;
 
@@ -333,6 +336,14 @@ public void setTaskExecLogIndexingEnabled(boolean taskExecLogIndexingEnabled) {
         this.taskExecLogIndexingEnabled = taskExecLogIndexingEnabled;
     }
 
+    public boolean isTaskIndexingEnabled() {
+        return taskIndexingEnabled;
+    }
+
+    public void setTaskIndexingEnabled(boolean taskIndexingEnabled) {
+        this.taskIndexingEnabled = taskIndexingEnabled;
+    }
+
     public boolean isAsyncIndexingEnabled() {
         return asyncIndexingEnabled;
     }

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
@@ -513,7 +513,7 @@ public void updateTask(TaskModel taskModel) {
              * of tasks on a system failure. So only index for each update if async indexing is not enabled.
              * If it *is* enabled, tasks will be indexed only when a workflow is in terminal state.
              */
-            if (!properties.isAsyncIndexingEnabled()) {
+            if (!properties.isAsyncIndexingEnabled() && properties.isTaskIndexingEnabled()) {
                 indexDAO.indexTask(new TaskSummary(taskModel.toTask()));
             }
         } catch (TerminateWorkflowException e) {