|
23 | 23 | import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.http; |
24 | 24 | import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.listen; |
25 | 25 | import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.toOne; |
| 26 | +import static io.serverlessworkflow.fluent.spec.dsl.DSL.auth; |
26 | 27 | import static io.serverlessworkflow.fluent.spec.dsl.DSL.use; |
27 | 28 | import static org.junit.jupiter.api.Assertions.assertEquals; |
28 | 29 | import static org.junit.jupiter.api.Assertions.assertInstanceOf; |
|
41 | 42 | import io.serverlessworkflow.fluent.func.dsl.FuncDSL; |
42 | 43 | import io.serverlessworkflow.fluent.func.dsl.FuncEmitSpec; |
43 | 44 | import io.serverlessworkflow.fluent.func.dsl.FuncListenSpec; |
44 | | -import io.serverlessworkflow.impl.WorkflowApplication; |
45 | | -import io.serverlessworkflow.impl.WorkflowDefinition; |
46 | 45 | import java.net.URI; |
47 | 46 | import java.nio.charset.StandardCharsets; |
48 | 47 | import java.util.List; |
@@ -433,21 +432,4 @@ void call_with_preconfigured_http_spec() { |
433 | 432 | .getUse()); |
434 | 433 | assertEquals(Map.of("foo", "bar"), http.getWith().getBody()); |
435 | 434 | } |
436 | | - |
437 | | - @Test |
438 | | - void set_with_map() { |
439 | | - try (WorkflowApplication app = WorkflowApplication.builder().build()) { |
440 | | - Workflow workflow = |
441 | | - FuncWorkflowBuilder.workflow() |
442 | | - .tasks(f -> f.set(s -> s.expr(Map.of("message", "hello world!")))) |
443 | | - .build(); |
444 | | - |
445 | | - WorkflowDefinition workflowDefinition = app.workflowDefinition(workflow); |
446 | | - |
447 | | - Map<String, Object> output = |
448 | | - workflowDefinition.instance(Map.of()).start().join().asMap().orElseThrow(); |
449 | | - |
450 | | - assertEquals(Map.of("message", "hello world!"), output); |
451 | | - } |
452 | | - } |
453 | 435 | } |
0 commit comments