_ExecutionsAPI

Namespace for execution lifecycle and inspection operations.

Functions

func__init__(self, client) -> None

paramself

paramclientKitaruClient

Returns

None

func_rest_store(self) -> RestZenStore

Return a REST-backed zen store required for runtime log retrieval.

paramself

Returns

zenml.zen_stores.rest_zen_store.RestZenStore

func_resolve_log_endpoint_hint(self) -> str | None

Resolve a best-effort endpoint hint for log-retrieval errors.

paramself

Returns

str | None

func_fetch_log_payload(self, *, path, source) -> builtins.list[Mapping[str, Any]]

Call a log endpoint and normalize the response payload shape.

paramself

parampathstr

paramsourcestr

Returns

builtins.builtins.list[collections.abc.Mapping[str, typing.Any]]

funclogs(self, exec_id, *, checkpoint=None, source='step', limit=None) -> builtins.list[LogEntry]

Fetch runtime log entries for an execution.

paramself

paramexec_idstr

paramcheckpointstr | None

= None

paramsourcestr

= 'step'

paramlimitint | None

= None

Returns

builtins.builtins.list[kitaru._client._models.LogEntry]

funcpending_waits(self, exec_id) -> builtins.list[PendingWait]

List all pending wait conditions for an execution.

paramself

paramexec_idstr

Returns

builtins.builtins.list[kitaru._client._models.PendingWait]

func_resolve_wait_condition(self, exec_id, *, wait, resolution, value=None) -> Execution

Resolve a pending wait condition with the given resolution.

paramself

paramexec_idstr

paramwaitstr

paramresolutionstr

paramvalueAny | None

= None

Returns

kitaru._client._models.Execution

funcinput(self, exec_id, *, wait, value) -> Execution

Provide input to a waiting execution.

paramself

paramexec_idstr

paramwaitstr

paramvalueAny

Returns

kitaru._client._models.Execution

funcabort_wait(self, exec_id, *, wait) -> Execution

Abort a pending wait condition on an execution.

paramself

paramexec_idstr

paramwaitstr

Returns

kitaru._client._models.Execution

funcretry(self, exec_id) -> Execution

Retry a failed execution as same-execution recovery.

paramself

paramexec_idstr

Returns

kitaru._client._models.Execution

funcresume(self, exec_id) -> Execution

Resume a paused execution after all waits are resolved.

paramself

paramexec_idstr

Returns

kitaru._client._models.Execution

funcreplay(self, exec_id, *, from_, overrides=None, **flow_inputs) -> Execution

Replay an execution from a checkpoint boundary.

paramself

paramexec_idstr

paramfrom_str

paramoverridesdict[str, Any] | None

= None

paramflow_inputsAny

= {}

Returns

kitaru._client._models.Execution

funcget(self, exec_id) -> Execution

Get and map one execution by ID.

paramself

paramexec_idstr

Returns

kitaru._client._models.Execution

funclist(self, *, flow=None, status=None, limit=None) -> builtins.list[Execution]

List executions with optional flow/status filters.

paramself

paramflowstr | None

= None

paramstatusExecutionStatus | str | None

= None

paramlimitint | None

= None

Returns

builtins.builtins.list[kitaru._client._models.Execution]

funclatest(self, *, flow=None, status=None) -> Execution

Return the most recent execution for a filter set.

paramself

paramflowstr | None

= None

paramstatusExecutionStatus | str | None

= None

Returns

kitaru._client._models.Execution

funccancel(self, exec_id) -> Execution

Cancel an execution if supported by the backend state.

paramself

paramexec_idstr

Returns

kitaru._client._models.Execution

_ExecutionsAPI

Functions

On this page