Skip to content

Commit 66737df

Browse files
committed
updated sequence demo
Signed-off-by: Dmitrii Tikhomirov <[email protected]>
1 parent 9cab274 commit 66737df

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

experimental/fluent/agentic/src/test/java/io/serverlessworkflow/fluent/agentic/LC4JEquivalenceIT.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import static io.serverlessworkflow.fluent.agentic.dsl.AgenticDSL.conditional;
2020
import static io.serverlessworkflow.fluent.agentic.dsl.AgenticDSL.doTasks;
2121
import static io.serverlessworkflow.fluent.agentic.dsl.AgenticDSL.loop;
22-
import static io.serverlessworkflow.fluent.spec.dsl.DSL.tasks;
22+
import static io.serverlessworkflow.fluent.agentic.dsl.AgenticDSL.tryCatch;
2323
import static org.assertj.core.api.Assertions.assertThat;
2424
import static org.junit.jupiter.api.Assertions.assertEquals;
2525

@@ -49,7 +49,7 @@ public void sequentialWorkflow() {
4949

5050
Workflow wf =
5151
workflow("seqFlow")
52-
.tasks(tasks -> tasks.sequence("process", creativeWriter, audienceEditor, styleEditor))
52+
.sequence("process", creativeWriter, audienceEditor, styleEditor)
5353
.build();
5454

5555
List<TaskItem> items = wf.getDo();
@@ -120,8 +120,9 @@ public void loopWorkflowWithMaxIterations() {
120120

121121
Predicate<AgenticScope> until = s -> s.readState("score", 0).doubleValue() >= 0.8;
122122

123-
Workflow wf =
124-
AgentWorkflowBuilder.workflow("retryFlow").tasks(loop(until, scorer, 5, editor)).build();
123+
tryCatch(loop(until, scorer, 5, editor));
124+
125+
Workflow wf = workflow("retryFlow").loop(until, scorer, 5, editor).build();
125126

126127
List<TaskItem> items = wf.getDo();
127128
assertThat(items).hasSize(1);
@@ -187,7 +188,7 @@ public void errorHandling() {
187188

188189
Workflow wf =
189190
workflow("seqFlow")
190-
.tasks(tasks -> tasks.sequence("process", creativeWriter, audienceEditor, styleEditor))
191+
.sequence("process", creativeWriter, audienceEditor, styleEditor)
191192
.build();
192193

193194
List<TaskItem> items = wf.getDo();

experimental/fluent/agentic/src/test/java/io/serverlessworkflow/fluent/agentic/README.md

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ String story = (String) novelCreator.invoke(input);
8080
### Serverless Workflow
8181

8282
```java
83-
Workflow wf = workflow("seqFlow").tasks(tasks -> tasks.sequence("process", creativeWriter, audienceEditor, styleEditor)).build();
83+
Workflow wf = workflow("seqFlow").sequence("process", creativeWriter, audienceEditor, styleEditor).build();
8484

8585
try (WorkflowApplication app = WorkflowApplication.builder().build()) {
8686
String result = app.workflowDefinition(wf).instance(input).start().get().asText().orElseThrow();
@@ -151,10 +151,8 @@ String story = styledWriter.writeStoryWithStyle("dragons and wizards", "comedy")
151151
```java
152152
Predicate<AgenticScope> until = s -> s.readState("score", 0).doubleValue() >= 0.8;
153153

154-
Workflow wf =
155-
AgentWorkflowBuilder.workflow("retryFlow")
156-
.tasks(loop(until, scorer, 5, editor))
157-
.build();
154+
Workflow wf = workflow("retryFlow").loop(until, scorer, 5, editor).build();
155+
158156

159157
Map<String, Object> input =
160158
Map.of(

0 commit comments

Comments
 (0)