GraphRuntime

Runs compiled graphs on durable threads.

start begins a run: on a new thread from the graph's entry, on a thread whose latest run completed by applying the input to its committed state. It refuses a thread with an incomplete execution (GraphError.IncompleteRun). recover continues an incomplete execution from its latest checkpoint without new input: tasks with a pending write are not run again, and failed or unstarted tasks run once more (per-node retry policy is Stage 1).

subscribe replays a thread's committed events after a sequence number and then delivers new ones as their commits succeed, in ascending order with no gaps or duplicates, followed by live progress as it happens. Events are delivered on the committing thread; a dedicated ordered dispatcher with bounded queues is part of the run API (#1271).