docstr: Validate whether the kubeflow operators are valid
docstr_tok: ["Validate","whether","the","kubeflow","operators","are","valid"]
code: def validate_kubeflow_operators(self, experiment_config):
      """Validate whether the kubeflow operators are valid"""
      if experiment_config.get("kubeflowConfig"):
          if (
              experiment_config.get("kubeflowConfig").get("operator")
              == "tf-operator"
          ):
              if (
                  experiment_config.get("trial").get("master")
                  is not None
              ):
                  raise SchemaError(
                      "kubeflow with tf-operator can not set master"
                  )
              if experiment_config.get("trial").get("worker") is None:
                  raise SchemaError(
                      "kubeflow with tf-operator must set worker"
                  )
          elif (
              experiment_config.get("kubeflowConfig").get("operator")
              == "pytorch-operator"
          ):
              if experiment_config.get("trial").get("ps") is not None:
                  raise SchemaError(
                      "kubeflow with pytorch-operator can not set ps"
                  )
              if experiment_config.get("trial").get("master") is None:
                  raise SchemaError(
                      "kubeflow with pytorch-operator must set master"
                  )
  
          if (
              experiment_config.get("kubeflowConfig").get("storage")
              == "nfs"
          ):
              if (
                  experiment_config.get("kubeflowConfig").get("nfs")
                  is None
              ):
                  raise SchemaError("please set nfs configuration!")
          elif (
              experiment_config.get("kubeflowConfig").get("storage")
              == "azureStorage"
          ):
              if (
                  experiment_config.get("kubeflowConfig").get(
                      "azureStorage"
                  )
                  is None
              ):
                  raise SchemaError(
                      "please set azureStorage configuration!"
                  )
          elif (
              experiment_config.get("kubeflowConfig").get("storage")
              is None
          ):
              if experiment_config.get("kubeflowConfig").get(
                  "azureStorage"
              ):
                  raise SchemaError("please set storage type!")
  
imports: import json
  import os
  from schema import And, Optional, Or, Regex, Schema, SchemaError
  from nni.tools.package_utils.tuner_factory import create_validator_instance
  from .common_utils import get_yml_content, print_warning
  from .constants import SCHEMA_PATH_ERROR, SCHEMA_RANGE_ERROR, SCHEMA_TYPE_ERROR
label_desc: Use image node_id 5 for calling the NNIConfigSchema obj's underlying member method code with example usage: obj.validate_kubeflow_operators(experiment_config) without return types