Struct Command 

pub struct Command {
    pub command_id: String,
    pub execution_id: i64,
    pub step: String,
    pub tool_kind: String,
    pub input: Value,
}

One command the worker will dispatch to a tool.

The shape mirrors the Python-side noetl.command row + envelope as of v2.103.x — keep the field names aligned so wire-format compatibility is automatic. R-1.3 will add the remaining fields (input, render context, parent execution id, etc.) when the worker reaches feature parity with the Python worker.

Fields

command_id: String

Stable identifier for this command. CLI generates a UUID; the worker uses the snowflake id from noetl.command.

execution_id: i64

Execution this command belongs to.

R-1.2 PR-2a: aligned to i64 to match the worker’s CommandNotification.execution_id and the Python noetl.command.execution_id bigint column.

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").

input: Value

Tool-specific input payload, already rendered against the merged step context.

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.