Skip to content

Commit

Permalink
address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
danielvegamyhre committed Feb 13, 2024
1 parent 3b0257c commit bc8b320
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion api/jobset/v1alpha2/jobset_webhook.go
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ const (

// Error message returned by JobSet validation if the generated pod names
// will be longer than 63 characters.
podNameTooLongErrorMsg = "JobSet name is too long, job names generated for this JobSet will exceed 63 characters"
podNameTooLongErrorMsg = "JobSet name is too long, pod names generated for this JobSet will exceed 63 characters"

// Error message returned by JobSet validation if the network subdomain
// will be longer than 63 characters.
Expand Down
6 changes: 3 additions & 3 deletions pkg/webhooks/pod_admission_webhook.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ func (p *podWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (ad
return nil, err
}
if !leaderScheduled {
return nil, fmt.Errorf("leader pod not yet scheduled, not creating follower pod %q", pod.Name)
return nil, fmt.Errorf("leader pod not yet scheduled, not creating follower pod. this is an expected, transient error.")
}
return nil, nil
}
Expand All @@ -87,7 +87,7 @@ func (p *podWebhook) leaderPodForFollower(ctx context.Context, pod *corev1.Pod)
log := ctrl.LoggerFrom(ctx)
leaderPodName, err := genLeaderPodName(pod)
if err != nil {
log.V(3).Info("leader pod (%s) for follower pod does not exist or has not been scheduled yet", leaderPodName)
log.Error(err, "getting leader pod name for follower pod")
return nil, err
}

Expand All @@ -99,7 +99,7 @@ func (p *podWebhook) leaderPodForFollower(ctx context.Context, pod *corev1.Pod)

// Validate there is only 1 leader pod for this job.
if len(podList.Items) != 1 {
return nil, fmt.Errorf("incorrect number of leader pods for this job (expected 1, got %d)", len(podList.Items))
return nil, fmt.Errorf("expected 1 leader pod (%s), but got %d. this is an expected, transient error.", leaderPodName, len(podList.Items))
}

// Check if the leader pod is scheduled.
Expand Down

0 comments on commit bc8b320

Please sign in to comment.