Skip to content

Commit 8e9ec51

Browse files
committed
added conditionalSequence and conditionalParallel
Signed-off-by: Dmitrii Tikhomirov <[email protected]>
1 parent da42e17 commit 8e9ec51

File tree

1 file changed

+8
-0
lines changed
  • experimental/fluent/agentic/src/main/java/io/serverlessworkflow/fluent/agentic/dsl

1 file changed

+8
-0
lines changed

experimental/fluent/agentic/src/main/java/io/serverlessworkflow/fluent/agentic/dsl/AgenticDSL.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,14 @@ public static AgentTaskConfigurer conditional(Predicate<?> predicate, Object age
144144
return list -> list.agent(agent).when(predicate);
145145
}
146146

147+
public static AgentTaskConfigurer conditionalSequence(Predicate<?> predicate, Object... agents) {
148+
return list -> list.sequence(agents).when(predicate);
149+
}
150+
151+
public static AgentTaskConfigurer conditionalParallel(Predicate<?> predicate, Object... agents) {
152+
return list -> list.parallel(agents).when(predicate);
153+
}
154+
147155
public static AgentTaskConfigurer emit(Consumer<FuncEmitTaskBuilder> event) {
148156
return list -> list.emit(event);
149157
}

0 commit comments

Comments
 (0)