func isSubmitterExitCodeRetryable()

in pkg/flink/handler.go [231:240]

• 10 lines of code
• 3 McCabe index (conditional complexity)

func isSubmitterExitCodeRetryable(ctx context.Context, exitCode int32) bool {
	config := GetFlinkConfig()
	for _, ec := range config.NonRetryableExitCodes {
		if exitCode == ec {
			logger.Infof(ctx, "Found non-retryable exit code: %v", ec)
			return false
		}
	}
	return true
}