https://flyte.org logo
#contribute
Title
# contribute
f

Fabio Grätz

06/12/2023, 6:42 PM
pod_helper.go
detecting preemptions:
Copy code
if code == "Shutdown" || code == "Terminated" {
		return pluginsCore.PhaseInfoSystemRetryableFailure(Interrupted, message, &info), nil
	}
So this counts against the system retriable failures I assume? Whereas e.g. for kubeflow plugins:
Copy code
case commonOp.JobFailed:
		details := fmt.Sprintf("Job failed:\n\t%v - %v", currentCondition.Reason, currentCondition.Message)
		return pluginsCore.PhaseInfoRetryableFailure(flyteerr.DownstreamSystemError, details, &taskPhaseInfo), nil
So is it correct that in the 2nd case a preemption counts against the retries configured in the task decorator whereas for normal pods it doesn’t?