From 6c3d3db81094de2e27be4288c32ba99f24356356 Mon Sep 17 00:00:00 2001 From: Joshua Palis Date: Mon, 9 Oct 2023 21:18:49 +0000 Subject: [PATCH] Addressing PR comments (Part 3) Signed-off-by: Joshua Palis --- .../flowframework/FlowFrameworkPlugin.java | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) 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); } }