diff --git a/experimental/fluent/func/pom.xml b/experimental/fluent/func/pom.xml
index 5beaf49d1..dcf2aa96f 100644
--- a/experimental/fluent/func/pom.xml
+++ b/experimental/fluent/func/pom.xml
@@ -45,17 +45,5 @@
${version.org.mockito}
test
-
- io.serverlessworkflow
- serverlessworkflow-impl-model
- ${project.version}
- test
-
-
- io.serverlessworkflow
- serverlessworkflow-impl-jackson
- ${project.version}
- test
-
\ No newline at end of file
diff --git a/experimental/fluent/func/src/test/java/io/serverlessworkflow/fluent/func/FuncDSLTest.java b/experimental/fluent/func/src/test/java/io/serverlessworkflow/fluent/func/FuncDSLTest.java
index 2e07737cc..3dbe95094 100644
--- a/experimental/fluent/func/src/test/java/io/serverlessworkflow/fluent/func/FuncDSLTest.java
+++ b/experimental/fluent/func/src/test/java/io/serverlessworkflow/fluent/func/FuncDSLTest.java
@@ -23,6 +23,7 @@
import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.http;
import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.listen;
import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.toOne;
+import static io.serverlessworkflow.fluent.spec.dsl.DSL.auth;
import static io.serverlessworkflow.fluent.spec.dsl.DSL.use;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertInstanceOf;
@@ -41,8 +42,6 @@
import io.serverlessworkflow.fluent.func.dsl.FuncDSL;
import io.serverlessworkflow.fluent.func.dsl.FuncEmitSpec;
import io.serverlessworkflow.fluent.func.dsl.FuncListenSpec;
-import io.serverlessworkflow.impl.WorkflowApplication;
-import io.serverlessworkflow.impl.WorkflowDefinition;
import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.List;
@@ -433,21 +432,4 @@ void call_with_preconfigured_http_spec() {
.getUse());
assertEquals(Map.of("foo", "bar"), http.getWith().getBody());
}
-
- @Test
- void set_with_map() {
- try (WorkflowApplication app = WorkflowApplication.builder().build()) {
- Workflow workflow =
- FuncWorkflowBuilder.workflow()
- .tasks(f -> f.set(s -> s.expr(Map.of("message", "hello world!"))))
- .build();
-
- WorkflowDefinition workflowDefinition = app.workflowDefinition(workflow);
-
- Map output =
- workflowDefinition.instance(Map.of()).start().join().asMap().orElseThrow();
-
- assertEquals(Map.of("message", "hello world!"), output);
- }
- }
}
diff --git a/experimental/lambda/src/test/java/io/serverless/workflow/impl/executors/func/FluentDSLCallTest.java b/experimental/lambda/src/test/java/io/serverless/workflow/impl/executors/func/FluentDSLCallTest.java
index fb8c8d940..23c019083 100644
--- a/experimental/lambda/src/test/java/io/serverless/workflow/impl/executors/func/FluentDSLCallTest.java
+++ b/experimental/lambda/src/test/java/io/serverless/workflow/impl/executors/func/FluentDSLCallTest.java
@@ -17,6 +17,7 @@
import static io.serverlessworkflow.fluent.func.dsl.FuncDSL.function;
import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import io.serverlessworkflow.api.types.FlowDirectiveEnum;
import io.serverlessworkflow.api.types.Workflow;
@@ -26,6 +27,7 @@
import io.serverlessworkflow.impl.WorkflowInstance;
import java.util.Collection;
import java.util.List;
+import java.util.Map;
import java.util.concurrent.ExecutionException;
import org.junit.jupiter.api.Test;
@@ -112,4 +114,21 @@ void testSwitch() throws InterruptedException, ExecutionException {
assertThat(definition.instance(4).start().get().asNumber().orElseThrow()).isEqualTo(0);
}
}
+
+ @Test
+ void set_with_map() {
+ try (WorkflowApplication app = WorkflowApplication.builder().build()) {
+ Workflow workflow =
+ FuncWorkflowBuilder.workflow()
+ .tasks(f -> f.set(s -> s.expr(Map.of("message", "hello world!"))))
+ .build();
+
+ WorkflowDefinition workflowDefinition = app.workflowDefinition(workflow);
+
+ Map output =
+ workflowDefinition.instance(Map.of()).start().join().asMap().orElseThrow();
+
+ assertEquals(Map.of("message", "hello world!"), output);
+ }
+ }
}