Kitaru
Python SDKflow

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, *, observed_started_at=None, analytics_metadata=None, track_terminal_if_finished=False) -> None

Initialize a flow handle.

paramself
paramrunPipelineRunResponse

Initial pipeline run response.

paramobserved_started_atfloat | None
= None

SDK-observed start time from time.perf_counter.

paramanalytics_metadatadict[str, Any] | None
= None

Privacy-safe metadata captured at submission time.

paramtrack_terminal_if_finishedbool
= False

Emit terminal analytics immediately when the initial run is already terminal.

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.

flow

Previous Page

inspection

Next Page

On this page

AttributesFunctions