Struct ExecutionsClient 

pub struct ExecutionsClient { /* private fields */ }

Sub-client for execution operations that are not project-scoped (lookup, resume, cancel, document helpers, await). Obtained via AkribesClient::executions().

For project-scoped operations (run, list, etc.), see ScopedExecutionsClient via [crate::client::ProjectScope::executions].

Implementations

impl ExecutionsClient

pub async fn resume( &self, execution_id: &str, token: &str, data: Value, ) -> Result<Value>

Resume a suspended checkpoint within a running execution.

pub async fn cancel(&self, execution_id: &str) -> Result<bool>

Cancel a specific execution by ID; returns true if it was cancelled.

pub async fn children( &self, execution_id: &str, ) -> Result<Vec<ExecutionChildSummary>>

List child executions spawned by execution_id via the engine’s spawn_child_execution callback (#1054). Returns an empty Vec when no children exist (the common case for v1 where parent-linkage columns are typically NULL). Mirrors TS executions.children and Python executions.children.

pub async fn get(&self, execution_id: &str) -> Result<Option<ExecutionStatus>>

Fetch the full status record for an execution.

pub async fn tasks( &self, execution_id: &str, ) -> Result<Option<ExecutionTasksResponse>>

Per-task cost / token / duration breakdown for an execution (GET /executions/{id}/tasks). Reads from the execution_tasks table populated as TaskEnd events arrive, so callers don’t have to parse the event JSON to recover this data. Useful for monolith workflows where there are no spawned children — every agent invocation lives in execution_tasks keyed by task_name.

404 → Ok(None) (the execution doesn’t exist or isn’t accessible to this token), matching get / get_output. Mirrors the TS SDK’s executions.tasks.

pub async fn get_output( &self, execution_id: &str, ) -> Result<Option<ExecutionOutput>>

Fetch only the output (status, error, result) for an execution.

pub async fn get_events( &self, execution_id: &str, after_id: Option<i64>, limit: Option<i64>, types: Option<&str>, ) -> Result<Option<ExecutionEvents>>

Return the persisted event stream for an execution. types is an optional comma-separated allowlist ("TaskEnd,Error,WorkflowEnd") that lets callers slim down responses on long workflows.

pub async fn get_document( &self, document_id: &str, ) -> Result<Option<DocumentMeta>>

Get document metadata by ID.

pub async fn get_document_markdown(&self, document_id: &str) -> Result<String>

Get converted markdown for a document.

pub async fn get_document_url(&self, document_id: &str) -> Result<String>

Get a presigned download URL for the original document file.

pub async fn reconvert_document(&self, document_id: &str) -> Result<Value>

Retry conversion on a failed document.

pub async fn run_from_node( &self, project_id: i64, script_name: &str, seed_env: HashMap<String, Value>, skip_node_ids: Vec<usize>, channel: Option<&str>, inputs: Option<HashMap<String, Value>>, ) -> Result<RunResult>

Run a script from a specific point with pre-seeded environment values.

Convenience wrapper that doesn’t require building a ScopedExecutionsClient first — useful for callers (e.g. akribes-mcp) that already know the project_id numerically. Forwards to ScopedExecutionsClient::run_from.

seed_env carries pre-computed variable values for nodes already completed by a prior execution; skip_node_ids lists those node IDs so the engine skips re-running them. channel defaults to draft.

pub async fn await_execution( &self, execution_id: &str, timeout_ms: Option<u64>, poll_interval_ms: Option<u64>, ) -> Result<ExecutionOutput>

Poll get_output until the execution reaches a terminal state.

pub async fn await_result( &self, execution_id: &str, timeout_ms: Option<u64>, poll_interval_ms: Option<u64>, ) -> Result<ExecutionOutput>

Cross-SDK naming alias for [await_execution]. Mirrors the Python SDK’s await_result; forwarded verbatim so callers porting examples across SDKs don’t trip on the rename. Refs #109 (item 3: method-naming consistency).

Trait Implementations

impl Clone for ExecutionsClient

fn clone(&self) -> ExecutionsClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionsClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.