diff --git a/pkg/registry/apis/provisioning/jobs/persistentstore.go b/pkg/registry/apis/provisioning/jobs/persistentstore.go index e6abbe50d08..af75d5a0ba3 100644 --- a/pkg/registry/apis/provisioning/jobs/persistentstore.go +++ b/pkg/registry/apis/provisioning/jobs/persistentstore.go @@ -379,6 +379,7 @@ func (s *persistentStore) cleanupClaims(ctx context.Context) error { func (s *persistentStore) Insert(ctx context.Context, job *provisioning.Job) (*provisioning.Job, error) { s.generateJobName(job) // Side-effect: updates the job's name. + ctx = request.WithNamespace(ctx, job.GetNamespace()) obj, err := s.jobStore.Create(ctx, job, nil, &metav1.CreateOptions{}) if apierrors.IsAlreadyExists(err) { return nil, apifmt.Errorf("job '%s' in '%s' already exists: %w", job.GetName(), job.GetNamespace(), err)