sagemaker.mlops.local.local_pipeline_session

sagemaker.mlops.local.local_pipeline_session#

Local Pipeline Session - extends LocalSession with pipeline execution capabilities.

Classes

LocalPipelineSession(*args, **kwargs)

Extends LocalSession with pipeline execution capabilities.
class sagemaker.mlops.local.local_pipeline_session.LocalPipelineSession(*args, **kwargs)[source]#

Bases: LocalSession

Extends LocalSession with pipeline execution capabilities.

This class provides local pipeline execution functionality that was previously in LocalSession. It’s now in the MLOps package since pipeline orchestration is an MLOps concern.

Usage:

from sagemaker.mlops.local import LocalPipelineSession from sagemaker.mlops.workflow import Pipeline

session = LocalPipelineSession() session.create_pipeline(pipeline, “My pipeline”)

create_pipeline(pipeline, pipeline_description, **kwargs)[source]#

Create a local pipeline.

Parameters:

  • pipeline (Pipeline) – Pipeline object

  • pipeline_description (str) – Description of the pipeline

Returns:

Pipeline metadata (PipelineArn)

delete_pipeline(PipelineName)[source]#

Delete the local pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

Pipeline metadata (PipelineArn)

describe_pipeline(PipelineName)[source]#

Describe the pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

Pipeline metadata (PipelineArn, PipelineDefinition, LastModifiedTime, etc)

start_pipeline_execution(PipelineName, **kwargs)[source]#

Start the pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

_LocalPipelineExecution object

update_pipeline(pipeline, pipeline_description, **kwargs)[source]#

Update a local pipeline.

Parameters:

  • pipeline (Pipeline) – Pipeline object

  • pipeline_description (str) – Description of the pipeline

Returns:

Pipeline metadata (PipelineArn)

Contents