Use v-threads for AbstractFutureStore

Signed-off-by: Paolo Di Tommaso <[email protected]>
seqeralabs · Nov 26, 2024 · 1d42c83 · 1d42c83
1 parent 06e7a7f
commit 1d42c83
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy b/src/main/groovy/io/seqera/wave/service/data/future/AbstractFutureStore.groovy
@@ -26,6 +26,7 @@ import java.util.concurrent.TimeoutException
 import groovy.transform.CompileStatic
 import groovy.util.logging.Slf4j
 import io.micronaut.context.annotation.Value
+import io.micronaut.scheduling.TaskExecutors
 import io.seqera.wave.encoder.EncodingStrategy
 import jakarta.inject.Inject
 import jakarta.inject.Named
@@ -55,7 +56,7 @@ abstract class AbstractFutureStore<V> implements FutureStore<String,V> {
     private volatile Duration pollInterval
 
     @Inject
-    @Named('future-store-executor')
+    @Named(TaskExecutors.BLOCKING)
     private ExecutorService executor
 
     AbstractFutureStore(FutureHash<String> store, EncodingStrategy<V> encodingStrategy) {

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
@@ -41,9 +41,6 @@ micronaut:
     stream-executor:
       type: FIXED
       number-of-threads: 16
-    future-store-executor:
-      type : FIXED
-      number-of-threads : 32
   netty:
     event-loops:
       stream-pool: