Merge branch 'main' into ContainerTask

Author: fjtirado

.gitattributes

@@ -1 +1,2 @@
-* text eol=lf
+* text eol=lf
+*.db -text -eol -working-tree-encoding -merge -diff

.github/project.yml

@@ -1,3 +1,4 @@
+# 7.4.0 - (4 round)
 release:
   current-version: 7.4.0.Final
   next-version: 8.0.0-SNAPSHOT

.github/workflows/release.yml

@@ -5,6 +5,7 @@ on:
     types: [closed]
     paths:
       - '.github/project.yml'
+  workflow_dispatch: {}
 
 permissions:
   contents: write
@@ -60,7 +61,12 @@ jobs:
       - name: Maven release ${{steps.metadata.outputs.current-version}}
         run: |
           git checkout -b release
-          mvn -B release:prepare -Prelease -DreleaseVersion=${{steps.metadata.outputs.current-version}} -DdevelopmentVersion=${{steps.metadata.outputs.next-version}}
+          mvn -B release:prepare -DperformRelease -Prelease -DreleaseVersion=${{steps.metadata.outputs.current-version}} -DdevelopmentVersion=${{steps.metadata.outputs.next-version}}
+          
+          git restore --staged --worktree -- impl/test/db-samples/** 2>/dev/null || true
+          git clean -fd -- impl/test/db-samples 2>/dev/null || true
+    
+          git status --porcelain
           cat release.properties
           git checkout ${{github.base_ref}}
           git rebase release

examples/pom.xml

@@ -4,6 +4,7 @@
         <groupId>io.serverlessworkflow</groupId>
         <artifactId>serverlessworkflow-parent</artifactId>
         <version>8.0.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
     </parent>
     <name>Serverless Workflow :: Examples</name>
     <artifactId>serverlessworkflow-examples</artifactId>

experimental/fluent/agentic-langchain4j/src/main/java/io/serverlessworkflow/fluent/agentic/langchain4j/AbstractAgentService.java

@@ -66,7 +66,7 @@ public S beforeCall(Consumer<AgenticScope> beforeCall) {
   }
 
   @SuppressWarnings("unchecked")
-  public S outputName(String outputName) {
+  public S outputKey(String outputName) {
     Function<DefaultAgenticScope, Object> outputFunction = cog -> cog.readState(outputName);
     this.workflowBuilder.outputAs(outputFunction, DefaultAgenticScope.class);
     this.workflowBuilder.document(

experimental/fluent/agentic-langchain4j/src/main/java/io/serverlessworkflow/fluent/agentic/langchain4j/WorkflowInvocationHandler.java

@@ -65,7 +65,7 @@ private static void writeAgenticScopeState(
     }
   }
 
-  private String outputName() {
+  private String outputKey() {
     Object outputName =
         this.workflow
             .getDocument()
@@ -81,12 +81,12 @@ private String outputName() {
   @Override
   public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
     AgenticScopeRegistry registry = registry();
-    // outputName
+    // outputKey
     if (method.getDeclaringClass() == AgentSpecification.class) {
       return switch (method.getName()) {
         case "name" -> this.workflow.getDocument().getName();
         case "description" -> this.workflow.getDocument().getSummary();
-        case "outputName" -> outputName();
+        case "outputKey" -> outputKey();
         default ->
             throw new UnsupportedOperationException(
                 "Unknown method on AgentInstance class : " + method.getName());
@@ -135,7 +135,7 @@ private Object executeWorkflow(AgenticScope agenticScope, Method method, Object[
                   () ->
                       new IllegalArgumentException(
                           "Workflow hasn't returned a AgenticScope object."));
-      Object result = output.readState(outputName());
+      Object result = output.readState(outputKey());
 
       return method.getReturnType().equals(ResultWithAgenticScope.class)
           ? new ResultWithAgenticScope<>(output, result)

experimental/fluent/agentic-langchain4j/src/test/java/io/serverlessworkflow/fluent/agentic/langchain4j/SequentialAgentServiceImplTest.java

@@ -64,7 +64,7 @@ void shouldSetOutputName_inDocumentMetadata() {
     String outputName = "myOutputName";
     SequentialAgentServiceImpl<DummyAgent> service =
         (SequentialAgentServiceImpl<DummyAgent>)
-            SequentialAgentServiceImpl.builder(DummyAgent.class).outputName(outputName);
+            SequentialAgentServiceImpl.builder(DummyAgent.class).outputKey(outputName);
 
     // when
     Workflow wf = service.getDefinition();

experimental/fluent/agentic-langchain4j/src/test/java/io/serverlessworkflow/fluent/agentic/langchain4j/WorkflowAgentsIT.java

@@ -40,28 +40,28 @@ void sequential_agents_tests() {
         spy(
             AgenticServices.agentBuilder(CreativeWriter.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     AudienceEditor audienceEditor =
         spy(
             AgenticServices.agentBuilder(AudienceEditor.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     StyleEditor styleEditor =
         spy(
             AgenticServices.agentBuilder(StyleEditor.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     UntypedAgent novelCreator =
         builder
             .sequenceBuilder()
             .subAgents(creativeWriter, audienceEditor, styleEditor)
-            .outputName("story")
+            .outputKey("story")
             .build();
 
     Map<String, Object> input =

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

@@ -44,7 +44,7 @@ public void verifyAgentCall() {
     Agents.MovieExpert movieExpert =
         spy(
             AgenticServices.agentBuilder(Agents.MovieExpert.class)
-                .outputName("movies")
+                .outputKey("movies")
                 .chatModel(BASE_MODEL)
                 .build());
 

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

@@ -178,10 +178,11 @@ public void errorHandling() {
 
     Map<String, Object> input =
         Map.of(
-            "style", "fantasy",
+            "topic", "fantasy",
+            "style", "funny",
             "audience", "young adults");
 
-    Map<String, Object> result;
+    Map<String, Object> result = null;
     try (WorkflowApplication app = WorkflowApplication.builder().build()) {
       result = app.workflowDefinition(wf).instance(input).start().get().asMap().orElseThrow();
     } catch (Exception e) {
@@ -191,7 +192,6 @@ public void errorHandling() {
     assertThat(result).containsKey("story");
   }
 
-  @SuppressWarnings("unchecked")
   @Test
   @DisplayName("Conditional agents via choice(...)")
   public void conditionalWorkflow() {
@@ -211,7 +211,7 @@ public void conditionalWorkflow() {
                     conditional(RequestCategory.LEGAL::equals, legalExpert)))
             .build();
 
-    Map<String, Object> input = Map.of("question", "What is the best treatment for a common cold?");
+    Map<String, Object> input = Map.of("request", "What is the best treatment for a common cold?");
 
     Map<String, Object> result;
     try (WorkflowApplication app = WorkflowApplication.builder().build()) {