chore(framework): add message queue todo in AgentGateway

This commit is contained in:
2026-03-03 11:48:59 +08:00
parent d462f02960
commit 85cc5cace8

View File

@@ -13,6 +13,8 @@ import work.slhaf.partner.api.agent.runtime.interaction.flow.RunningFlowContext
abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> { abstract class AgentInteractionAdapter<I : AgentInputData, O : AgentOutputData, C : RunningFlowContext> {
// TODO whether to support message queue, to avoid concurrence problem in data and agent stats
fun submit(inputData: I): O { fun submit(inputData: I): O {
val finalInputData: C = parseInputData(inputData) val finalInputData: C = parseInputData(inputData)
val outputContext: C = call(finalInputData) val outputContext: C = call(finalInputData)