From 4392c89ec79325bc331785eaeb0ccc6bece8b32e Mon Sep 17 00:00:00 2001 From: Ludovic DEHON Date: Mon, 3 Feb 2025 21:27:04 +0100 Subject: [PATCH] fix(core): process runner are not serialized correctly on worker close #7053 --- .../core/models/tasks/runners/TaskRunnerResult.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/core/src/main/java/io/kestra/core/models/tasks/runners/TaskRunnerResult.java b/core/src/main/java/io/kestra/core/models/tasks/runners/TaskRunnerResult.java index 764014ffeb6..1a61d8a5180 100644 --- a/core/src/main/java/io/kestra/core/models/tasks/runners/TaskRunnerResult.java +++ b/core/src/main/java/io/kestra/core/models/tasks/runners/TaskRunnerResult.java @@ -2,23 +2,26 @@ import io.kestra.core.models.tasks.Output; import lombok.AllArgsConstructor; -import lombok.Builder; import lombok.Getter; import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +import javax.annotation.Nullable; @AllArgsConstructor @Getter -@Builder +@SuperBuilder @NoArgsConstructor public class TaskRunnerResult implements Output { private int exitCode; + private AbstractLogConsumer logConsumer; + + @Nullable private T details; - @SuppressWarnings("unchecked") public TaskRunnerResult(int exitCode, AbstractLogConsumer logConsumer) { this.exitCode = exitCode; this.logConsumer = logConsumer; - this.details = (T) TaskRunnerDetailResult.builder().build(); } }