Remove featurePrepareDispatcher with limitedParallelism from AIAgentPipeline

Author: serge-p7v

agents/agents-core/src/commonMain/kotlin/ai/koog/agents/core/feature/pipeline/AIAgentFunctionalPipeline.kt

@@ -11,7 +11,7 @@ import kotlinx.datetime.Clock
  * workflows or data processing tasks that do not require graph-based
  * data structures.
  *
- * @param clock The clock used for time-based operations within the pipeline
+ * @property clock The clock used for time-based operations within the pipeline
  */
 public class AIAgentFunctionalPipeline(clock: Clock = Clock.System) : AIAgentPipeline(clock) {
 

agents/agents-core/src/commonMain/kotlin/ai/koog/agents/core/feature/pipeline/AIAgentPipeline.kt

@@ -58,9 +58,6 @@ import ai.koog.prompt.llm.LLModel
 import ai.koog.prompt.message.Message
 import ai.koog.prompt.streaming.StreamFrame
 import io.github.oshai.kotlinlogging.KotlinLogging
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.withContext
 import kotlinx.datetime.Clock
 import kotlin.reflect.KClass
 import kotlin.reflect.KType
@@ -81,7 +78,7 @@ import kotlin.reflect.safeCast
  * through a flexible interception system. Features can be installed with custom configurations
  * and can hook into different stages of the agent's execution lifecycle.
  *
- * @param clock Clock instance for time-related operations
+ * @property clock Clock instance for time-related operations
  */
 public abstract class AIAgentPipeline(public val clock: Clock) {
 
@@ -106,8 +103,6 @@ public abstract class AIAgentPipeline(public val clock: Clock) {
         public val featureConfig: FeatureConfig
     )
 
-    private val featurePrepareDispatcher = Dispatchers.Default.limitedParallelism(5)
-
     /**
      * Map of registered features and their configurations.
      * Keys are feature storage keys, values are feature configurations.
@@ -145,15 +140,11 @@ public abstract class AIAgentPipeline(public val clock: Clock) {
     protected val llmStreamingEventHandlers: MutableMap<AIAgentStorageKey<*>, LLMStreamingEventHandler> = mutableMapOf()
 
     internal suspend fun prepareFeatures() {
-        withContext(featurePrepareDispatcher) {
-            registeredFeatures.values.map { it.featureConfig }.forEach { featureConfig ->
-                featureConfig.messageProcessors.map { processor ->
-                    launch {
-                        logger.debug { "Start preparing processor: ${processor::class.simpleName}" }
-                        processor.initialize()
-                        logger.debug { "Finished preparing processor: ${processor::class.simpleName}" }
-                    }
-                }
+        registeredFeatures.values.map { it.featureConfig }.forEach { featureConfig ->
+            featureConfig.messageProcessors.map { processor ->
+                logger.debug { "Start preparing processor: ${processor::class.simpleName}" }
+                processor.initialize()
+                logger.debug { "Finished preparing processor: ${processor::class.simpleName}" }
             }
         }
     }