diff --git a/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java b/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java index 810674c47..0bac15c61 100644 --- a/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java +++ b/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java @@ -109,14 +109,15 @@ public List getRestHandlers( @Override public List> getExecutorBuilders(Settings settings) { // TODO : Determine final size/queueSize values for the provision thread pool - FixedExecutorBuilder provisionThreadPool = new FixedExecutorBuilder( - settings, - PROVISION_THREAD_POOL, - OpenSearchExecutors.allocatedProcessors(settings), - 10, - FLOW_FRAMEWORK_THREAD_POOL_PREFIX + PROVISION_THREAD_POOL + return ImmutableList.of( + new FixedExecutorBuilder( + settings, + PROVISION_THREAD_POOL, + OpenSearchExecutors.allocatedProcessors(settings), + 10, + FLOW_FRAMEWORK_THREAD_POOL_PREFIX + PROVISION_THREAD_POOL + ) ); - return ImmutableList.of(provisionThreadPool); } }