hydromodpy.workflow.events#

Event-stream writer over workflow_events.

Append-only emission of step lifecycle and heartbeat events. The table serves as the canonical source of truth for liveness diagnostics; the view v_workflow_heartbeats derives the current heartbeat from the event stream.

All writes go through the CatalogBackend port; the workflow layer never calls connection.execute directly so the T3 port-driven writes contract is preserved.

Classes

WorkflowEventStream(catalog)

Append-only writer for the workflow_events table.