diff --git a/pkg/microservice/aslan/core/workflow/service/workflow/workflow_template_binding.go b/pkg/microservice/aslan/core/workflow/service/workflow/workflow_template_binding.go index c8e7cc779a..472f2feecc 100644 --- a/pkg/microservice/aslan/core/workflow/service/workflow/workflow_template_binding.go +++ b/pkg/microservice/aslan/core/workflow/service/workflow/workflow_template_binding.go @@ -582,45 +582,9 @@ func validateFrontendWorkflowDelta(base *commonmodels.WorkflowV4, patches []*com } rendered = next } - if err := validateJobExecutePolicies(base, rendered); err != nil { - return nil, nil, err - } return patches, rendered, nil } -func validateJobExecutePolicies(template, rendered *commonmodels.WorkflowV4) error { - renderedJobs := make(map[string]*commonmodels.Job) - for _, stage := range rendered.Stages { - if stage == nil { - continue - } - for _, job := range stage.Jobs { - if job != nil { - renderedJobs[job.Name] = job - } - } - } - - for _, stage := range template.Stages { - if stage == nil { - continue - } - for _, templateJob := range stage.Jobs { - if templateJob == nil { - continue - } - renderedJob, ok := renderedJobs[templateJob.Name] - if !ok { - continue - } - if !reflect.DeepEqual(templateJob.ExecutePolicy, renderedJob.ExecutePolicy) { - return fmt.Errorf("job %q execute_policy must be consistent with workflow template", templateJob.Name) - } - } - } - return nil -} - func validateTemplateBindingPatch(patch *commonmodels.JSONPatchOperation) error { if patch == nil { return fmt.Errorf("nil json patch operation")