We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fac2213 commit 4378567Copy full SHA for 4378567
1 file changed
impl/core/src/main/java/io/serverlessworkflow/impl/executors/AbstractTaskExecutor.java
@@ -246,9 +246,7 @@ public CompletableFuture<TaskContext> apply(
246
p -> t.output(p.apply(workflowContext, t, t.rawOutput())));
247
outputSchemaValidator.ifPresent(s -> s.validate(t.output()));
248
contextProcessor.ifPresent(
249
- p ->
250
- workflowContext.context(
251
- p.apply(workflowContext, t, workflowContext.context())));
+ p -> workflowContext.context(p.apply(workflowContext, t, t.output())));
252
contextSchemaValidator.ifPresent(s -> s.validate(workflowContext.context()));
253
t.completedAt(Instant.now());
254
publishEvent(
0 commit comments