From 940d6f5c50da18f22ccd1990407dd4b427aef797 Mon Sep 17 00:00:00 2001
From: fjtirado <ftirados@redhat.com>
Date: Wed, 19 Nov 2025 12:46:48 +0100
Subject: [PATCH] Minor format

Signed-off-by: fjtirado <ftirados@redhat.com>
---
 .../func/JavaContextFunctionCallExecutor.java    | 14 ++++++++------
 .../func/JavaFilterFunctionCallExecutor.java     | 16 ++++++++++------
 .../executors/func/JavaFunctionCallExecutor.java | 12 +++++-------
 3 files changed, 23 insertions(+), 19 deletions(-)

diff --git a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaContextFunctionCallExecutor.java b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaContextFunctionCallExecutor.java
index 91cb5c488..dd3b37ca7 100644
--- a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaContextFunctionCallExecutor.java
+++ b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaContextFunctionCallExecutor.java
@@ -22,7 +22,6 @@
 import io.serverlessworkflow.impl.WorkflowContext;
 import io.serverlessworkflow.impl.WorkflowDefinition;
 import io.serverlessworkflow.impl.WorkflowModel;
-import io.serverlessworkflow.impl.WorkflowModelFactory;
 import io.serverlessworkflow.impl.executors.CallableTask;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
@@ -31,7 +30,7 @@ public class JavaContextFunctionCallExecutor<T, V>
     implements CallableTask<CallJava.CallJavaContextFunction<T, V>> {
 
   private JavaContextFunction<T, V> function;
-  private Optional<Class<T>> inputClass = Optional.empty();
+  private Optional<Class<T>> inputClass;
 
   @Override
   public void init(CallJava.CallJavaContextFunction<T, V> task, WorkflowDefinition definition) {
@@ -42,10 +41,13 @@ public void init(CallJava.CallJavaContextFunction<T, V> task, WorkflowDefinition
   @Override
   public CompletableFuture<WorkflowModel> apply(
       WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
-    WorkflowModelFactory mf = workflowContext.definition().application().modelFactory();
-    T typedIn = JavaFuncUtils.convertT(input, inputClass);
-    V out = function.apply(typedIn, workflowContext);
-    return CompletableFuture.completedFuture(mf.fromAny(input, out));
+    return CompletableFuture.completedFuture(
+        workflowContext
+            .definition()
+            .application()
+            .modelFactory()
+            .fromAny(
+                input, function.apply(JavaFuncUtils.convertT(input, inputClass), workflowContext)));
   }
 
   @Override
diff --git a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFilterFunctionCallExecutor.java b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFilterFunctionCallExecutor.java
index 765177dce..d346f2b10 100644
--- a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFilterFunctionCallExecutor.java
+++ b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFilterFunctionCallExecutor.java
@@ -22,7 +22,6 @@
 import io.serverlessworkflow.impl.WorkflowContext;
 import io.serverlessworkflow.impl.WorkflowDefinition;
 import io.serverlessworkflow.impl.WorkflowModel;
-import io.serverlessworkflow.impl.WorkflowModelFactory;
 import io.serverlessworkflow.impl.executors.CallableTask;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
@@ -31,7 +30,7 @@ public class JavaFilterFunctionCallExecutor<T, V>
     implements CallableTask<CallJava.CallJavaFilterFunction<T, V>> {
 
   private JavaFilterFunction<T, V> function;
-  private Optional<Class<T>> inputClass = Optional.empty();
+  private Optional<Class<T>> inputClass;
 
   @Override
   public void init(CallJava.CallJavaFilterFunction<T, V> task, WorkflowDefinition definition) {
@@ -42,10 +41,15 @@ public void init(CallJava.CallJavaFilterFunction<T, V> task, WorkflowDefinition
   @Override
   public CompletableFuture<WorkflowModel> apply(
       WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
-    WorkflowModelFactory mf = workflowContext.definition().application().modelFactory();
-    T typedIn = JavaFuncUtils.convertT(input, inputClass);
-    V out = function.apply(typedIn, workflowContext, taskContext);
-    return CompletableFuture.completedFuture(mf.fromAny(input, out));
+    return CompletableFuture.completedFuture(
+        workflowContext
+            .definition()
+            .application()
+            .modelFactory()
+            .fromAny(
+                input,
+                function.apply(
+                    JavaFuncUtils.convertT(input, inputClass), workflowContext, taskContext)));
   }
 
   @Override
diff --git a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFunctionCallExecutor.java b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFunctionCallExecutor.java
index 17e05ae74..b5cf8287d 100644
--- a/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFunctionCallExecutor.java
+++ b/experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaFunctionCallExecutor.java
@@ -21,7 +21,6 @@
 import io.serverlessworkflow.impl.WorkflowContext;
 import io.serverlessworkflow.impl.WorkflowDefinition;
 import io.serverlessworkflow.impl.WorkflowModel;
-import io.serverlessworkflow.impl.WorkflowModelFactory;
 import io.serverlessworkflow.impl.executors.CallableTask;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
@@ -33,10 +32,6 @@ public class JavaFunctionCallExecutor<T, V>
   private Function<T, V> function;
   private Optional<Class<T>> inputClass;
 
-  static String fromInt(Integer integer) {
-    return Integer.toString(integer);
-  }
-
   public void init(CallJava.CallJavaFunction<T, V> task, WorkflowDefinition definition) {
     function = task.function();
     inputClass = task.inputClass();
@@ -45,9 +40,12 @@ public void init(CallJava.CallJavaFunction<T, V> task, WorkflowDefinition defini
   @Override
   public CompletableFuture<WorkflowModel> apply(
       WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
-    WorkflowModelFactory modelFactory = workflowContext.definition().application().modelFactory();
     return CompletableFuture.completedFuture(
-        modelFactory.fromAny(input, function.apply(JavaFuncUtils.convertT(input, inputClass))));
+        workflowContext
+            .definition()
+            .application()
+            .modelFactory()
+            .fromAny(input, function.apply(JavaFuncUtils.convertT(input, inputClass))));
   }
 
   @Override