sagemaker.mlops.local

Local pipeline execution for SageMaker MLOps.

class sagemaker.mlops.local.LocalPipelineSession(*args, **kwargs)

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)

Create a local pipeline.

Parameters:

• pipeline (Pipeline) – Pipeline object

• pipeline_description (str) – Description of the pipeline

Returns:

Pipeline metadata (PipelineArn)

delete_pipeline(PipelineName)

Delete the local pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

Pipeline metadata (PipelineArn)

describe_pipeline(PipelineName)

Describe the pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

Pipeline metadata (PipelineArn, PipelineDefinition, LastModifiedTime, etc)

start_pipeline_execution(PipelineName, **kwargs)

Start the pipeline.

Parameters:

PipelineName (str) – Name of the pipeline

Returns:

_LocalPipelineExecution object

update_pipeline(pipeline, pipeline_description, **kwargs)

Update a local pipeline.

Parameters:

• pipeline (Pipeline) – Pipeline object

• pipeline_description (str) – Description of the pipeline

Returns:

Pipeline metadata (PipelineArn)

Modules

exceptions	Exceptions for local pipeline execution.
local_pipeline_session	Local Pipeline Session - extends LocalSession with pipeline execution capabilities.
pipeline	Local Pipeline Executor
pipeline_entities	Local pipeline execution entities.