Struct Command 

pub struct Command {
    pub command_id: String,
    pub execution_id: i64,
    pub step: String,
    pub tool_kind: String,
    pub input: Value,
    pub render_context: HashMap<String, Value>,
    pub attempts: u32,
}

One command the worker will dispatch to a tool.

The shape mirrors the Python-side noetl.command row + envelope

• render-context map. Keep field naming aligned with the wire format so JSON serde round-trips both directions.

Fields

command_id: String

Stable identifier for this command. Worker uses the snowflake id from noetl.command; future sources (HTTP poll, local-mode mock) may use UUIDs.

execution_id: i64

Execution this command belongs to. i64 mirrors the Python noetl.command.execution_id bigint column and the BridgeContext.execution_id field in the cli’s tools_bridge.

step: String

Step name from the playbook (e.g. "fetch_calendar").

tool_kind: String

Tool kind that dispatch will route to (e.g. "http", "postgres", "rhai"). Matches noetl-tools’ registry kind.

input: Value

Tool-specific input payload (the ToolConfig.config JSON passed to noetl_tools::registry::Tool::execute).

render_context: HashMap<String, Value>

Variables already rendered against the merged step context (workload + vars + step results). Tools read this through noetl_tools::context::ExecutionContext.variables.

R-1.2 PR-2d-1: added so the worker’s Command.render_context() method maps cleanly onto this field.

attempts: u32

Number of times this command has been attempted (incremented by the control plane on each redelivery). Used by the dispatcher for backoff and giving-up decisions.

R-1.2 PR-2d-1: added so retry policy decisions can flow through the trait.

Trait Implementations

impl Clone for Command

fn clone(&self) -> Command

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Command

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Command

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Command

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.