Kitaru

FlowHandle

Handle for a running or finished flow execution.

Attributes

attributeexec_idstr

Execution identifier for this flow run.

attributestatusExecutionStatus

Current execution status.

Functions

func__init__(self, run) -> None

Initialize a flow handle.

paramself
paramrunPipelineRunResponse

Initial pipeline run response.

Returns

None
funcwait(self) -> Any

Block until execution finishes and return its result.

paramself

Returns

typing.Any

The flow return value.

funcget(self) -> Any

Get the flow result without waiting.

paramself

Returns

typing.Any

The flow return value.

func_refresh(self) -> PipelineRunResponse

Refresh the cached run model from the server.

paramself

Returns

zenml.models.PipelineRunResponse

On this page