tempo.serve.pipeline module

class tempo.serve.pipeline.Pipeline(name: str, pipeline_func: Callable[[Any], Any] = None, protocol: Optional[tempo.serve.protocol.Protocol] = None, models: tempo.serve.pipeline.PipelineModels = None, local_folder: str = None, uri: str = None, inputs: Optional[Union[Type, List, Dict[str, Type]]] = None, outputs: Optional[Union[Type, List, Dict[str, Type]]] = None, conda_env: str = None, runtime_options: Union[tempo.serve.metadata.KubernetesRuntimeOptions, tempo.serve.metadata.DockerOptions, tempo.serve.metadata.EnterpriseRuntimeOptions] = DockerOptions(runtime='tempo.seldon.SeldonDockerRuntime', state_options=StateOptions(state_type=<StateTypes.LOCAL: 'LOCAL'>, key_prefix='', host='', port=''), insights_options=InsightsOptions(worker_endpoint='', batch_size=1, parallelism=1, retries=3, window_time=0, mode_type=<InsightRequestModes.NONE: 'NONE'>, in_asyncio=False), ingress_options=IngressOptions(ingress='tempo.ingress.istio.IstioIngress', ssl=False, verify_ssl=True)), description: str = '')

Bases: tempo.serve.base.BaseModel

deploy(runtime: tempo.serve.base.Runtime)
deploy_models(runtime: tempo.serve.base.Runtime)
save(save_env=True)
set_remote(val: bool)
set_runtime_options_override(runtime_options: Union[tempo.serve.metadata.KubernetesRuntimeOptions, tempo.serve.metadata.DockerOptions, tempo.serve.metadata.EnterpriseRuntimeOptions])
to_k8s_yaml(runtime: tempo.serve.base.Runtime) → str

Get k8s yaml

undeploy(runtime: tempo.serve.base.Runtime)

Undeploy all models and pipeline.

undeploy_models(runtime: tempo.serve.base.Runtime)
wait_ready(runtime: tempo.serve.base.Runtime, timeout_secs: int = None) → bool
class tempo.serve.pipeline.PipelineModels

Bases: types.SimpleNamespace

ModelExportKlass

alias of tempo.serve.model.Model

items()
keys()
remote_copy()
values()