slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(framework): wrap module execution in Result and report failures via exception handler

Browse Source
This commit is contained in:
slhafzjw
2026-04-12 17:33:11 +08:00
parent c14e6f84e7
commit e0f955694d
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Partner-Framework/src/main/java/work/slhaf/partner/framework/agent/interaction/AgentRuntime.kt
View File

@@ -7,11 +7,13 @@ import kotlinx.coroutines.channels.Channel
import work.slhaf.partner.framework.agent.config.Config
import work.slhaf.partner.framework.agent.config.ConfigRegistration
import work.slhaf.partner.framework.agent.config.Configurable
import work.slhaf.partner.framework.agent.exception.ExceptionReporterHandler
import work.slhaf.partner.framework.agent.factory.component.abstracts.AbstractAgentModule
import work.slhaf.partner.framework.agent.factory.context.AgentContext
import work.slhaf.partner.framework.agent.factory.context.ModuleContextData
import work.slhaf.partner.framework.agent.interaction.data.InteractionEvent
import work.slhaf.partner.framework.agent.interaction.flow.RunningFlowContext
import work.slhaf.partner.framework.agent.support.Result
import java.nio.file.Path
object AgentRuntime : Configurable, ConfigRegistration<ModuleMaskConfig> {
@@ -103,7 +105,8 @@ object AgentRuntime : Configurable, ConfigRegistration<ModuleMaskConfig> {
if (runningFlowContext.skippedModules.contains(module.moduleName)) {
return@async
}
module.execute(runningFlowContext)
Result.runCatching { module.execute(runningFlowContext) }
.onFailure { ExceptionReporterHandler.report(it) }
}
}
jobs.awaitAll()