text: # Copyright 2019 kubeflow.org.
  #
  # Licensed under the Apache License, Version 2.0 (the "License");
  # you may not use this file except in compliance with the License.
  # You may obtain a copy of the License at
  #
  #    http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  
  import kfp.dsl as dsl
  from kfp import components
  import json
  
  
  kfserving_op = components.load_component_from_url('https://raw.githubusercontent.com/kubeflow/pipelines/master/components/kubeflow/kfserving/component.yaml')
  
  @dsl.pipeline(
    name='kfserving pipeline',
    description='A pipeline for kfserving.'
  )
  def kfservingPipeline(
      action='create',
      model_name='max-image-segmenter',
      namespace='kubeflow',
      framework='custom',
      default_custom_model_spec='{"name": "image-segmenter", "image": "codait/max-image-segmenter:latest", "port": "5000"}'
  ):
  
      kfserving = kfserving_op(action=action,
                               model_name=model_name,
                               namespace=namespace,
                               framework=framework,
                               default_custom_model_spec=default_custom_model_spec)
  
  
  if __name__ == '__main__':
      import kfp.compiler as compiler
      compiler.Compiler().compile(kfservingPipeline, __file__ + '.tar.gz')
  