Initial values for dynamic settings

Signed-off-by: Owais Kazi <[email protected]>
opensearch-project · Nov 7, 2023 · 722f09d · 722f09d
1 parent 3d31567
commit 722f09d
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/org/opensearch/flowframework/common/FlowFrameworkSettings.java b/src/main/java/org/opensearch/flowframework/common/FlowFrameworkSettings.java
@@ -17,12 +17,12 @@ public class FlowFrameworkSettings {
     private FlowFrameworkSettings() {}
 
     /** The upper limit of max workflows that can be created  */
-    public static final int MAX_WORKFLOWS_LIMIT = 34;
+    public static final int MAX_WORKFLOWS_LIMIT = 1000;
 
     /** This setting sets max workflows that can be created  */
     public static final Setting<Integer> MAX_WORKFLOWS = Setting.intSetting(
         "plugins.flow_framework.max_workflows",
-        0,
+        100,
         0,
         MAX_WORKFLOWS_LIMIT,
         Setting.Property.NodeScope,

diff --git a/src/main/java/org/opensearch/flowframework/rest/AbstractSearchWorkflowAction.java b/src/main/java/org/opensearch/flowframework/rest/AbstractSearchWorkflowAction.java
@@ -30,7 +30,7 @@
 import java.util.List;
 
 import static org.opensearch.core.xcontent.ToXContent.EMPTY_PARAMS;
-import static org.opensearch.flowframework.common.FlowFrameworkFeatureEnabledSetting.FLOW_FRAMEWORK_ENABLED;
+import static org.opensearch.flowframework.common.FlowFrameworkSettings.FLOW_FRAMEWORK_ENABLED;
 import static org.opensearch.flowframework.util.RestHandlerUtils.getSourceContext;
 
 /**

diff --git a/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java b/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java
@@ -197,7 +197,7 @@ protected void doExecute(Task task, WorkflowRequest request, ActionListener<Work
      */
     protected void onSearchGlobalContext(SearchResponse response, ActionListener listener, Integer maxWorkflow) {
         if (response.getHits().getTotalHits().value >= maxWorkflow) {
-            String errorMessage = "Maximum workflows limit reached" + maxWorkflow;
+            String errorMessage = "Maximum workflows limit reached " + maxWorkflow;
             logger.error(errorMessage);
             listener.onFailure(new FlowFrameworkException(errorMessage, RestStatus.BAD_REQUEST));
         }