How commands work
- All commands for one execution enter one queue and are applied in the order sent. The caller’s response arrives only after the command has been applied.
- Commands for different executions are independent.
- Every command for a known execution is recorded in the execution log as applied or rejected, with the actor: the API key name (
key:<name>), a supervisor id, or the UI user.GET /api/control/auditlists who sent which command. - Before a command runs, reviewers can refuse it. A refusal returns
403and is logged. See Supervisors. - The pipeline is built for people and supervisors, not as a high-volume API.
Pause and resume
Pausing stops a node, or the whole execution, from taking new messages. The message being processed finishes. All time limits freeze while paused, so a pause never causes a timeout.Step
Step mode lets exactly n messages through a node, then pauses it again. Use it to watch a pipeline one message at a time.Breakpoints
A breakpoint holds a node before the first message whosepayload, a path inside the payload such as payload.order.id, or a metadata.key equals a given text. It is ordered and audited like any command.
Skip and unskip
Skipping a processor passes messages through it without calling its plugin, from the next message on. A message already inside the plugin finishes. Unskip resumes normal processing. Other node kinds reject skip.Stop
Three strengths of stopping an execution:Restart, restart from a node, and retry a node
429.