Struct Ctx 

pub struct Ctx { /* private fields */ }

Context threaded through every workflow and step.

Users never create or manage task IDs. The SDK handles everything via (parent_id, name) lookups — the unique constraint in the schema guarantees exactly-once step creation.

Implementations

impl Ctx

pub async fn start( db: &DatabaseConnection, name: &str, input: Option<Value>, ) -> Result<Self, DurableError>

Start or resume a root workflow by name.

let ctx = Ctx::start(&db, "ingest", json!({"crawl": "CC-2026"})).await?;

pub async fn step<T, F, Fut>(&self, name: &str, f: F) -> Result<T, DurableError>

where T: Serialize + DeserializeOwned, F: FnOnce() -> Fut, Fut: Future<Output = Result<T, DurableError>>,

Run a step. If already completed, returns saved output. Otherwise executes the closure, saves the result, and returns it.

let count: u32 = ctx.step("fetch_count", || async { api.get_count().await }).await?;

pub async fn child( &self, name: &str, input: Option<Value>, ) -> Result<Self, DurableError>

Start or resume a child workflow. Returns a new Ctx scoped to the child.

let child_ctx = ctx.child("embed_batch", json!({"vectors": 1000})).await?;
// use child_ctx.step(...) for steps inside the child
child_ctx.complete(json!({"done": true})).await?;

pub async fn is_completed(&self) -> Result<bool, DurableError>

Check if this workflow/child was already completed (for skipping in parent).

pub async fn get_output<T: DeserializeOwned>( &self, ) -> Result<Option<T>, DurableError>

Get the saved output if this task is completed.

pub async fn complete<T: Serialize>( &self, output: &T, ) -> Result<(), DurableError>

Mark this workflow as completed with an output value.

pub async fn fail(&self, error: &str) -> Result<(), DurableError>

Mark this workflow as failed.

pub fn db(&self) -> &DatabaseConnection

pub fn task_id(&self) -> Uuid

pub fn next_sequence(&self) -> i32