Struct RunsClient 

pub struct RunsClient { /* private fields */ }

Implementations

impl RunsClient

pub async fn create( &self, spec: WorkflowIntentSpec, ) -> Result<RunsCreateResponse, Error>

pub async fn create_with_options( &self, spec: WorkflowIntentSpec, options: RunsCreateOptions, ) -> Result<RunsCreateResponse, Error>

pub async fn create_with_session( &self, spec: WorkflowIntentSpec, session_id: Uuid, ) -> Result<RunsCreateResponse, Error>

pub async fn create_from_plan( &self, plan_hash: PlanHash, ) -> Result<RunsCreateResponse, Error>

Creates a workflow run using a precompiled plan hash.

Use crate::WorkflowsClient::compile to compile a workflow spec and obtain a plan_hash, then use this method to start runs without re-compiling each time. This is useful for workflows that are run repeatedly with the same structure but different inputs.

The plan_hash must have been compiled in the current server session; if the server has restarted since compilation, the plan will not be found and you’ll need to recompile.

pub async fn create_from_plan_with_options( &self, plan_hash: PlanHash, options: RunsCreateOptions, ) -> Result<RunsCreateResponse, Error>

Creates a workflow run using a precompiled plan hash with options.

See Self::create_from_plan for details on plan_hash usage.

pub async fn get(&self, run_id: RunId) -> Result<RunsGetResponse, Error>

pub async fn pending_tools( &self, run_id: RunId, ) -> Result<RunsPendingToolsResponse, Error>

pub async fn submit_tool_results( &self, run_id: RunId, req: RunsToolResultsRequest, ) -> Result<RunsToolResultsResponse, Error>

pub async fn stream_events( &self, run_id: RunId, after_seq: Option<i64>, limit: Option<i64>, ) -> Result<RunEventStreamHandle, Error>

Available on crate feature streaming only.

Trait Implementations

impl Clone for RunsClient

fn clone(&self) -> RunsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.