exo/lm-lib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: Bump version to 1.6.16 and refactor AgentExecutorService to improve context walking logic

Browse Source
This commit is contained in:
extio-de
2025-09-25 13:44:16 +02:00
parent ab1695f9a1
commit df8bc252ed
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/de/extio/lmlib/agent/AgentExecutorService.java
View File

@@ -69,6 +69,13 @@ public class AgentExecutorService implements InitializingBean, DisposableBean {
}
public List<AgentContext> walk(final BaseAgent agent, final AgentContext context, final Consumer<AgentContext> agentContextUpdateConsumer) {
if (!context.getGraph().isEmpty()) {
context.getGraph().add("‖");
}
return this.walkRecursive(agent, context, agentContextUpdateConsumer);
}
private List<AgentContext> walkRecursive(final BaseAgent agent, final AgentContext context, final Consumer<AgentContext> agentContextUpdateConsumer) {
LOGGER.debug("Agent: {}", agent.name());
this.discoverAgents(context);
@@ -96,7 +103,7 @@ public class AgentExecutorService implements InitializingBean, DisposableBean {
branchTasks.add(CompletableFuture.runAsync(() -> {
try {
responses.addAll(this.walk(branchAgent, branchContext, agentContextUpdateConsumer));
responses.addAll(this.walkRecursive(branchAgent, branchContext, agentContextUpdateConsumer));
}
catch (final Exception e) {
LOGGER.error("Error executing agent", e);