Struct RunsClient 

pub struct RunsClient { /* private fields */ }

The runs client is a client for interacting with task and workflow runs within Hatchet.

Implementations

impl RunsClient

pub async fn get( &self, workflow_run_id: &str, ) -> Result<GetWorkflowRunResponse, HatchetError>

Get a workflow run by its ID.

use hatchet_sdk::{Hatchet, EmptyModel};
#[tokio::main]
async fn main() {
    let hatchet = Hatchet::from_env().await.unwrap();
    let workflow_run = hatchet.workflow_rest_client.get("123").await.unwrap();
}

pub async fn subscribe_to_stream( &mut self, workflow_run_id: &str, ) -> Result<Pin<Box<dyn Stream<Item = Result<Vec<u8>, HatchetError>> + Send>>, HatchetError>

Subscribe to stream events for a workflow run. Returns an async Stream of byte chunks emitted by tasks via ctx.put_stream().

use hatchet_sdk::Hatchet;
use futures::StreamExt;
#[tokio::main]
async fn main() {
    let mut hatchet = Hatchet::from_env().await.unwrap();
    let mut stream = hatchet.workflow_rest_client.subscribe_to_stream("run-id").await.unwrap();
    while let Some(chunk) = stream.next().await {
        println!("Got chunk: {:?}", chunk.unwrap());
    }
}

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.

impl Debug for RunsClient

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

Formats the value using the given formatter.