func Validate()

in pkg/flink/validate.go [25:43]

• 16 lines of code
• 5 McCabe index (conditional complexity)

func Validate(job *flinkIdl.FlinkJob) error {
	err := job.Validate()
	if err != nil {
		return err
	}

	jarFiles := len(job.GetJarFiles()) + len(job.GetJflyte().GetArtifacts())
	if jarFiles == 0 {
		return fmt.Errorf("no artifacts provided")
	}

	if len(job.GetFlinkVersion()) != 0 {
		if _, err = version.NewVersion(job.GetFlinkVersion()); err != nil {
			return err
		}
	}

	return nil
}