workflow-runner

Writes the run-envelope (workflow.run-started / workflow.run-completed / workflow.run-failed) for a workflow run onto its workflow-run aggregate stream. Provides startAndRunWorkflow and registerEventTrigger for consumer features to wire up defineWorkflow-based workflows against domain events. Registers no workflows itself. Runs the resume loop for suspended wait/retry/waitForEvent steps (resume-due-runs job + resume-run handler); registerEventTrigger wires an event-wakeup subscriber per workflow that declares awaits so a waitForEvent step resumes as soon as its awaited event arrives, not just on timeout.

How it fits

The write commands this feature provides (Provides).

flowchart TB
  n_workflow_runner["workflow-runner"]
  subgraph how_provides["Provides"]
    n_cmd_workflow_runner_write_resume_run(["resume-run"])
  end
  n_workflow_runner --> n_cmd_workflow_runner_write_resume_run

Provides — write commands this feature registers (dispatch them through the command bus):

• workflow-runner:write:resume-run

Dependencies

• Requires: none
• Activation: always on (not toggleable)