Struct Step 

pub struct Step {
    pub run_id: String,
    pub step_number: u32,
    pub payload: Vec<u8>,
    pub headers: HashMap<String, String>,
    pub job_id: String,
    pub attempts: u32,
    pub cancel_token: CancellationToken,
}

A single step within a workflow run, handed to StepRunner::run_step.

Mirrors taquba::JobRecord: the payload is opaque application bytes and headers carries user metadata you set at submission (reserved workflow.* keys are filtered out before the runner sees them).

Fields

run_id: String

Caller-visible run identifier (the value passed to or generated by crate::RunSpec).

step_number: u32

Zero-based step number. Step 0 is always the first step of a run, with the original submission input as its payload.

payload: Vec<u8>

Application-defined bytes. For step 0 this is the submission input; for later steps it is the bytes returned by the previous step’s StepOutcome::Continue / StepOutcome::ContinueAfter.

headers: HashMap<String, String>

Submitter-supplied metadata, threaded through every step of the run. Reserved workflow.* headers are stripped before the runner sees them.

job_id: String

The Taquba job ID for this step, useful for tracing and lease renewal.

attempts: u32

How many times Taquba has attempted to deliver this step. 1 on the first attempt; >1 after a lease expiry / nack retry.

cancel_token: CancellationToken

Cooperative cancellation signal for the run. The runtime cancels this token when crate::WorkflowRuntime::cancel is called while this step is in flight, so a long-running runner (e.g. an LLM call, a slow HTTP request) can short-circuit instead of running to completion. Typical use:

tokio::select! {
    out = do_slow_work(step) => out,
    _ = step.cancel_token.cancelled() => {
        Ok(StepOutcome::Cancel { reason: "cooperative".into() })
    }
}

Runners that ignore the token remain correct: the runtime still discards the outcome of a cancelled step and fires the terminal hook with crate::TerminalStatus::Cancelled. Watching the token only reduces cancellation latency for slow steps; it doesn’t change semantics.

The token is run-scoped, not step-scoped: once cancelled, every subsequent step of the run (including any retry of this one) observes is_cancelled() == true immediately.

Trait Implementations

impl Clone for Step

fn clone(&self) -> Step

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Step

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

Formats the value using the given formatter.