diff --git a/experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/dsl/FuncDSL.java b/experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/dsl/FuncDSL.java
index ff2db37e..a419c6cc 100644
--- a/experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/dsl/FuncDSL.java
+++ b/experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/dsl/FuncDSL.java
@@ -222,13 +222,13 @@ public static <T> Consumer<FuncEmitTaskBuilder> event(
    *
    * @param type CloudEvent type
    * @param function function that maps workflow input to {@link CloudEventData}
-   * @param clazz expected input class for conversion
+   * @param inputClass expected input class for conversion
    * @param <T> input type
    * @return a consumer to configure {@link FuncEmitTaskBuilder}
    */
   public static <T> Consumer<FuncEmitTaskBuilder> event(
-      String type, Function<T, CloudEventData> function, Class<T> clazz) {
-    return OPS.event(type, function, clazz);
+      String type, Function<T, CloudEventData> function, Class<T> inputClass) {
+    return OPS.event(type, function, inputClass);
   }
 
   /**
@@ -236,12 +236,12 @@ public static <T> Consumer<FuncEmitTaskBuilder> event(
    * serializes the input to bytes using the configured JSON mapper.
    *
    * @param type CloudEvent type
-   * @param clazz input POJO class (used for typing and conversion)
+   * @param inputClass input POJO class (used for typing and conversion)
    * @param <T> input type
    * @return a consumer to configure {@link FuncEmitTaskBuilder}
    */
-  public static <T> Consumer<FuncEmitTaskBuilder> eventJson(String type, Class<T> clazz) {
-    return b -> new FuncEmitSpec().type(type).jsonData(clazz).accept(b);
+  public static <T> Consumer<FuncEmitTaskBuilder> eventJson(String type, Class<T> inputClass) {
+    return b -> new FuncEmitSpec().type(type).jsonData(inputClass).accept(b);
   }
 
   /**
@@ -249,13 +249,13 @@ public static <T> Consumer<FuncEmitTaskBuilder> eventJson(String type, Class<T>
    *
    * @param type CloudEvent type
    * @param serializer function producing bytes from the input
-   * @param clazz expected input class for conversion
+   * @param inputClass expected input class for conversion
    * @param <T> input type
    * @return a consumer to configure {@link FuncEmitTaskBuilder}
    */
   public static <T> Consumer<FuncEmitTaskBuilder> eventBytes(
-      String type, Function<T, byte[]> serializer, Class<T> clazz) {
-    return b -> new FuncEmitSpec().type(type).bytesData(serializer, clazz).accept(b);
+      String type, Function<T, byte[]> serializer, Class<T> inputClass) {
+    return b -> new FuncEmitSpec().type(type).bytesData(serializer, inputClass).accept(b);
   }
 
   /**
@@ -284,13 +284,13 @@ public static FuncPredicateEventConfigurer event(String type) {
    * type.
    *
    * @param fn the function to execute at runtime
-   * @param clazz expected input class for model conversion
+   * @param inputClass expected input class for model conversion
    * @param <T> input type
    * @param <R> result type
    * @return a call step which supports chaining (e.g., {@code .exportAs(...).when(...)})
    */
-  public static <T, R> FuncCallStep<T, R> function(Function<T, R> fn, Class<T> clazz) {
-    return new FuncCallStep<>(fn, clazz);
+  public static <T, R> FuncCallStep<T, R> function(Function<T, R> fn, Class<T> inputClass) {
+    return new FuncCallStep<>(fn, inputClass);
   }
 
   /**
@@ -440,13 +440,13 @@ public static <T, R> FuncCallStep<T, R> withUniqueId(UniqueIdBiFunction<T, R> fn
    * Create a fire-and-forget side-effect step (unnamed). The consumer receives the typed input.
    *
    * @param consumer side-effect function
-   * @param clazz expected input class for conversion
+   * @param inputClass expected input class for conversion
    * @param <T> input type
    * @return a {@link ConsumeStep} which can be chained and added via {@link
    *     #tasks(FuncTaskConfigurer...)}
    */
-  public static <T> ConsumeStep<T> consume(Consumer<T> consumer, Class<T> clazz) {
-    return new ConsumeStep<>(consumer, clazz);
+  public static <T> ConsumeStep<T> consume(Consumer<T> consumer, Class<T> inputClass) {
+    return new ConsumeStep<>(consumer, inputClass);
   }
 
   /**
@@ -454,12 +454,12 @@ public static <T> ConsumeStep<T> consume(Consumer<T> consumer, Class<T> clazz) {
    *
    * @param name task name
    * @param consumer side-effect function
-   * @param clazz expected input class
+   * @param inputClass expected input class
    * @param <T> input type
    * @return a named {@link ConsumeStep}
    */
-  public static <T> ConsumeStep<T> consume(String name, Consumer<T> consumer, Class<T> clazz) {
-    return new ConsumeStep<>(name, consumer, clazz);
+  public static <T> ConsumeStep<T> consume(String name, Consumer<T> consumer, Class<T> inputClass) {
+    return new ConsumeStep<>(name, consumer, inputClass);
   }
 
   /**
@@ -506,8 +506,8 @@ public static <T, R> FuncCallStep<T, R> agent(
    * @return a call step
    */
   public static <T, R> FuncCallStep<T, R> function(Function<T, R> fn) {
-    Class<T> clazz = ReflectionUtils.inferInputType(fn);
-    return new FuncCallStep<>(fn, clazz);
+    Class<T> inputClass = ReflectionUtils.inferInputType(fn);
+    return new FuncCallStep<>(fn, inputClass);
   }
 
   /**
@@ -520,8 +520,8 @@ public static <T, R> FuncCallStep<T, R> function(Function<T, R> fn) {
    * @return a named call step
    */
   public static <T, R> FuncCallStep<T, R> function(String name, Function<T, R> fn) {
-    Class<T> clazz = ReflectionUtils.inferInputType(fn);
-    return new FuncCallStep<>(name, fn, clazz);
+    Class<T> inputClass = ReflectionUtils.inferInputType(fn);
+    return new FuncCallStep<>(name, fn, inputClass);
   }
 
   /**
@@ -529,13 +529,14 @@ public static <T, R> FuncCallStep<T, R> function(String name, Function<T, R> fn)
    *
    * @param name task name
    * @param fn the function to execute
-   * @param clazz expected input class
+   * @param inputClass expected input class
    * @param <T> input type
    * @param <R> output type
    * @return a named call step
    */
-  public static <T, R> FuncCallStep<T, R> function(String name, Function<T, R> fn, Class<T> clazz) {
-    return new FuncCallStep<>(name, fn, clazz);
+  public static <T, R> FuncCallStep<T, R> function(
+      String name, Function<T, R> fn, Class<T> inputClass) {
+    return new FuncCallStep<>(name, fn, inputClass);
   }
 
   // ------------------  tasks ---------------- //
@@ -606,13 +607,13 @@ public static <T> EmitStep emit(String name, String type, Function<T, CloudEvent
    * @param name task name
    * @param type CloudEvent type
    * @param serializer function producing bytes
-   * @param clazz expected input class
+   * @param inputClass expected input class
    * @param <T> input type
    * @return a named {@link EmitStep}
    */
   public static <T> EmitStep emit(
-      String name, String type, Function<T, byte[]> serializer, Class<T> clazz) {
-    return new EmitStep(name, eventBytes(type, serializer, clazz));
+      String name, String type, Function<T, byte[]> serializer, Class<T> inputClass) {
+    return new EmitStep(name, eventBytes(type, serializer, inputClass));
   }
 
   /**
@@ -620,24 +621,25 @@ public static <T> EmitStep emit(
    *
    * @param type CloudEvent type
    * @param serializer function producing bytes
-   * @param clazz expected input class
+   * @param inputClass expected input class
    * @param <T> input type
    * @return an {@link EmitStep}
    */
-  public static <T> EmitStep emit(String type, Function<T, byte[]> serializer, Class<T> clazz) {
-    return new EmitStep(null, eventBytes(type, serializer, clazz));
+  public static <T> EmitStep emit(
+      String type, Function<T, byte[]> serializer, Class<T> inputClass) {
+    return new EmitStep(null, eventBytes(type, serializer, inputClass));
   }
 
   /**
    * Emit a JSON CloudEvent from a POJO input class (unnamed).
    *
    * @param type CloudEvent type
-   * @param clazz input POJO class
+   * @param inputClass input POJO class
    * @param <T> input type
    * @return an {@link EmitStep}
    */
-  public static <T> EmitStep emitJson(String type, Class<T> clazz) {
-    return new EmitStep(null, eventJson(type, clazz));
+  public static <T> EmitStep emitJson(String type, Class<T> inputClass) {
+    return new EmitStep(null, eventJson(type, inputClass));
   }
 
   /**
@@ -645,12 +647,12 @@ public static <T> EmitStep emitJson(String type, Class<T> clazz) {
    *
    * @param name task name
    * @param type CloudEvent type
-   * @param clazz input POJO class
+   * @param inputClass input POJO class
    * @param <T> input type
    * @return a named {@link EmitStep}
    */
-  public static <T> EmitStep emitJson(String name, String type, Class<T> clazz) {
-    return new EmitStep(name, eventJson(type, clazz));
+  public static <T> EmitStep emitJson(String name, String type, Class<T> inputClass) {
+    return new EmitStep(name, eventJson(type, inputClass));
   }
 
   /**