Skip to content

Commit

Permalink
fix(core): process runner are not serialized correctly on worker
Browse files Browse the repository at this point in the history
close #7053
  • Loading branch information
tchiotludo committed Feb 3, 2025
1 parent d74a31b commit 4392c89
Showing 1 changed file with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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<T extends TaskRunnerDetailResult> 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();
}
}

0 comments on commit 4392c89

Please sign in to comment.