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]): workspace_id (Union[None, Unset, int]): workspace_name (Union[None, Unset, str]):

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

Method generated by attrs for class PublishPipelineResponse202.

client
created_at
updated_at
def add_edge( self, name: str, tags: List[str] = []) -> 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.
def list_edges(self) -> List[wallaroo.edge.Edge]:

List all edges in a published pipeline.

class PipelinePublishList(typing.List[wallaroo.pipeline_publish.PipelinePublish]):

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

def sum_memory(values: List[str] = []) -> str: