tests

pkg/controllers/jobset_controller.go

@@ -516,7 +516,6 @@ func (r *JobSetReconciler) executeStartupPolicy(ctx context.Context, js *jobset.
 			counter = counter + 1
 		}
 	}
-	log.V(2).Info("detected startupPolicy, suspend all jobs")
 	if counter == len(ownedJobs.active) {
 		if js.ObjectMeta.Annotations == nil {
 			annotations := make(map[string]string)

pkg/controllers/jobset_controller_test.go

@@ -600,6 +600,38 @@ func TestConstructJobsFromTemplate(t *testing.T) {
 					Subdomain(jobSetName).Obj(),
 			},
 		},
+		{
+			name: "startup-policy",
+			js: testutils.MakeJobSet(jobSetName, ns).
+				StartupPolicy(&jobset.StartupPolicy{
+					TargetReplicatedJobStatuses: []jobset.TargetReplicatedJobStartup{
+						{
+						Name: replicatedJobName,
+						Status: jobset.Succeeded,
+						},
+				},
+				}).
+				EnableDNSHostnames(true).
+				NetworkSubdomain(jobSetName).
+				ReplicatedJob(testutils.MakeReplicatedJob(replicatedJobName).
+					Job(testutils.MakeJobTemplate(jobName, ns).Obj()).
+					Subdomain(jobSetName).
+					Replicas(1).
+					Obj()).
+				Obj(),
+			ownedJobs: &childJobs{},
+			want: []*batchv1.Job{
+				makeJob(&makeJobArgs{
+					jobSetName:        jobSetName,
+					replicatedJobName: replicatedJobName,
+					jobName:           "test-jobset-replicated-job-0",
+					ns:                ns,
+					replicas:          1,
+					jobIdx:            0}).
+					Suspend(true).
+					Subdomain(jobSetName).Obj(),
+			},
+		},
 	}
 
 	for _, tc := range tests {