wallaroo.pipeline_publish

class PipelinePublish(wallaroo.wallaroo_ml_ops_api_client.models.publish_pipeline_response_202.PublishPipelineResponse202):

Attributes: created_at (datetime.datetime): docker_run_variables (PublishPipelineResponse202DockerRunVariables): engine_config (EngineConfig): id (int): pipeline_name (str): pipeline_version_id (int): replaces (List['OldPublish']): status (PipelinePublishStatus): updated_at (datetime.datetime): user_images (List[str]): created_by (Union[None, Unset, str]): created_on_version (Union[Unset, AppVersion]): edge_bundles (Union[Unset, PublishPipelineResponse202EdgeBundles]): engine_url (Union[None, Unset, str]): error (Union[None, Unset, str]): If [PipelinePublish::status] is in the [PipelinePublishStatus::Error] state, this should be populated with the error that occurred. helm (Union['PipelinePublishHelm', None, Unset]): pipeline_url (Union[None, Unset, str]): pipeline_version_name (Union[None, Unset, str]):

PipelinePublish(client: wallaroo.client.Client, chart_url=None, **data)

Method generated by attrs for class PublishPipelineResponse202.

def add_edge( self, name: str, tags: List[str] = []) -> wallaroo.pipeline_publish.PipelinePublish:

Add new edge to a published pipeline.

def remove_edge(self, name: str):

Remove an edge to a published pipeline.

Parameters
  • str name: The name of the edge that will be removed. This is not limited to this pipeline.
Inherited Members
wallaroo.wallaroo_ml_ops_api_client.models.publish_pipeline_response_202.PublishPipelineResponse202
created_at
updated_at
docker_run_variables
engine_config
id
pipeline_name
pipeline_version_id
replaces
status
user_images
created_by
created_on_version
edge_bundles
engine_url
error
helm
pipeline_url
pipeline_version_name
additional_properties
to_dict
from_dict
additional_keys
class PipelinePublishList(typing.List[wallaroo.pipeline_publish.PipelinePublish]):

Wraps a list of published pipelines for display in a display-aware environment like Jupyter.

Inherited Members
builtins.list
list
clear
copy
append
insert
extend
pop
remove
index
count
reverse
sort
def sum_memory(values: List[str] = []) -> str: