From 7028ee35c1ad8aab1b1b7c13db49a199ca781661 Mon Sep 17 00:00:00 2001 From: Surinder Singh Date: Thu, 16 Apr 2020 10:26:32 -0700 Subject: [PATCH] Flyte node timeout is an usererror (#114) * Flyte node timeout is an usererror * Update executor.go --- pkg/controller/nodes/executor.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/controller/nodes/executor.go b/pkg/controller/nodes/executor.go index a02d51a72b..dafc3701d1 100644 --- a/pkg/controller/nodes/executor.go +++ b/pkg/controller/nodes/executor.go @@ -229,7 +229,8 @@ func (c *nodeExecutor) execute(ctx context.Context, h handler.Node, nCtx *nodeEx } if c.isTimeoutExpired(nodeStatus.GetLastAttemptStartedAt(), executionDeadline) { logger.Errorf(ctx, "Current execution for the node timed out; timeout configured: %v", executionDeadline) - phase = handler.PhaseInfoRetryableFailure("TimeoutExpired", fmt.Sprintf("task execution timeout [%s] expired", executionDeadline.String()), nil) + executionErr := &core.ExecutionError{Code: "TimeoutExpired", Message: fmt.Sprintf("task execution timeout [%s] expired", executionDeadline.String()), Kind: core.ExecutionError_USER} + phase = handler.PhaseInfoRetryableFailureErr(executionErr, nil) } }