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¶
-