hydromodpy.workflow.journal#

Append-only journal over workflow_steps in the project catalog.

Each pipeline step records a row at start (status running) and the runner finalises it at end (status completed / failed / aborted). The journal is the source of truth for resume decisions: it stores stable inputs_hash / outputs_hash digests and the workspace-relative artifact_uris written by the step. Live-simulation heartbeats are emitted through workflow_events by hydromodpy.workflow.heartbeat.HeartbeatPulse.

Classes

WorkflowJournal(catalog)

Append-only writer for the workflow_steps table.

WorkflowStepRow(step_id, run_id, step_order, ...)

One row from workflow_steps, materialised for the planner.