Skip to content

Commit 5760493

Browse files
committed
fix style
Signed-off-by: Dmitrii Tikhomirov <[email protected]>
1 parent 40fbfcb commit 5760493

File tree

1 file changed

+16
-12
lines changed

1 file changed

+16
-12
lines changed

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

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -180,18 +180,22 @@ public void parallelWorkflow() {
180180
})))
181181
.build();
182182

183-
Workflow wf = workflow("forkFlow")
184-
.tasks(d -> d
185-
.parallel("fanout", foodExpert, movieExpert)
186-
.callFn(fn((Map<String, List<String>> m) -> {
187-
var movies = m.getOrDefault("movies", List.of());
188-
var meals = m.getOrDefault("meals", List.of());
189-
return java.util.stream.IntStream
190-
.range(0, Math.min(movies.size(), meals.size()))
191-
.mapToObj(i -> new EveningPlan(movies.get(i), meals.get(i)))
192-
.toList();
193-
}))
194-
).build();
183+
Workflow wf =
184+
workflow("forkFlow")
185+
.tasks(
186+
d ->
187+
d.parallel("fanout", foodExpert, movieExpert)
188+
.callFn(
189+
fn(
190+
(Map<String, List<String>> m) -> {
191+
var movies = m.getOrDefault("movies", List.of());
192+
var meals = m.getOrDefault("meals", List.of());
193+
return java.util.stream.IntStream.range(
194+
0, Math.min(movies.size(), meals.size()))
195+
.mapToObj(i -> new EveningPlan(movies.get(i), meals.get(i)))
196+
.toList();
197+
})))
198+
.build();
195199

196200
List<TaskItem> items = wf.getDo();
197201
assertThat(items).hasSize(1);

0 commit comments

Comments
 (0)