in pkg/controllers/jobset_controller.go [722:735]
func numJobsExpectedToSucceed(js *jobset.JobSet) int {
total := 0
switch js.Spec.SuccessPolicy.Operator {
case jobset.OperatorAny:
total = 1
case jobset.OperatorAll:
for _, rjob := range js.Spec.ReplicatedJobs {
if replicatedJobMatchesSuccessPolicy(js, &rjob) {
total += rjob.Replicas
}
}
}
return total
}