Post Execution
zenml.post_execution
special
Deprecated post-execution utility functions.
pipeline
Implementation of the post-execution pipeline.
get_pipeline(pipeline)
(Deprecated) Fetches a pipeline model.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
pipeline |
str |
The name of the pipeline. |
required |
Returns:
Type | Description |
---|---|
Optional[PipelineResponse] |
The pipeline model. |
Source code in zenml/post_execution/pipeline.py
def get_pipeline(
pipeline: str,
) -> Optional["PipelineResponse"]:
"""(Deprecated) Fetches a pipeline model.
Args:
pipeline: The name of the pipeline.
Returns:
The pipeline model.
"""
logger.warning(
"`zenml.post_execution.get_pipeline()` is deprecated and will be "
"removed in a future release. Please use "
"`zenml.client.Client().get_pipeline()` instead."
)
return Client().get_pipeline(name_id_or_prefix=pipeline)
get_pipelines()
(Deprecated) Fetches all pipelines in the active workspace.
Returns:
Type | Description |
---|---|
List[PipelineResponse] |
A list of pipeline models. |
Source code in zenml/post_execution/pipeline.py
def get_pipelines() -> List["PipelineResponse"]:
"""(Deprecated) Fetches all pipelines in the active workspace.
Returns:
A list of pipeline models.
"""
logger.warning(
"`zenml.post_execution.get_pipelines()` is deprecated and will be "
"removed in a future release. Please use "
"`zenml.client.Client().list_pipelines()` instead."
)
return Client().list_pipelines().items
pipeline_run
Implementation of the post-execution pipeline run class.
get_run(name)
(Deprecated) Fetches the run with the given name.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
name |
str |
The name of the run to fetch. |
required |
Returns:
Type | Description |
---|---|
PipelineRunResponse |
The run with the given name. |
Source code in zenml/post_execution/pipeline_run.py
def get_run(name: str) -> "PipelineRunResponse":
"""(Deprecated) Fetches the run with the given name.
Args:
name: The name of the run to fetch.
Returns:
The run with the given name.
"""
logger.warning(
"`zenml.post_execution.get_run(<name>)` is deprecated and will be "
"removed in a future release. Please use "
"`zenml.client.Client().get_pipeline_run(<name>)` instead."
)
return Client().get_pipeline_run(name)
get_unlisted_runs()
(Deprecated) Fetches the 50 most recent unlisted runs.
Unlisted runs are runs that are not associated with any pipeline.
Returns:
Type | Description |
---|---|
List[PipelineRunResponse] |
A list of the 50 most recent unlisted runs. |
Source code in zenml/post_execution/pipeline_run.py
def get_unlisted_runs() -> List["PipelineRunResponse"]:
"""(Deprecated) Fetches the 50 most recent unlisted runs.
Unlisted runs are runs that are not associated with any pipeline.
Returns:
A list of the 50 most recent unlisted runs.
"""
logger.warning(
"`zenml.post_execution.get_unlisted_runs()` is deprecated and will be "
"removed in a future release. Please use "
"`zenml.client.Client().list_pipeline_runs(unlisted=True)` instead."
)
return Client().list_pipeline_runs(unlisted=True).items