Sprint 2: update runtime __init__ with checkpoint + state exports
Browse files
purpose_agent/runtime/__init__.py
CHANGED
|
@@ -3,12 +3,28 @@ Purpose Agent Runtime — Event-driven execution engine for v3.0.
|
|
| 3 |
|
| 4 |
Provides:
|
| 5 |
- PAEvent: canonical event schema
|
| 6 |
-
- EventKind: enumerated event types
|
|
|
|
| 7 |
- EventBus: async pub/sub with backpressure and replay
|
| 8 |
-
-
|
| 9 |
-
-
|
|
|
|
|
|
|
|
|
|
| 10 |
"""
|
| 11 |
-
from purpose_agent.runtime.events import PAEvent, EventKind, Visibility
|
| 12 |
-
from purpose_agent.runtime.event_bus import EventBus
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 13 |
|
| 14 |
-
__all__ = [
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 3 |
|
| 4 |
Provides:
|
| 5 |
- PAEvent: canonical event schema
|
| 6 |
+
- EventKind: enumerated event types
|
| 7 |
+
- Visibility: event visibility levels
|
| 8 |
- EventBus: async pub/sub with backpressure and replay
|
| 9 |
+
- RunState: typed execution state for checkpointing
|
| 10 |
+
- Checkpointer: protocol for durable state persistence
|
| 11 |
+
- InMemoryCheckpointer: testing
|
| 12 |
+
- JSONLCheckpointer: file-based, portable
|
| 13 |
+
- SQLiteCheckpointer: production, concurrent-safe
|
| 14 |
"""
|
| 15 |
+
from purpose_agent.runtime.events import PAEvent, EventKind, Visibility, create_event, TERMINAL_KINDS
|
| 16 |
+
from purpose_agent.runtime.event_bus import EventBus, parallel_merge
|
| 17 |
+
from purpose_agent.runtime.state import RunState, RunStatus, NodeState
|
| 18 |
+
from purpose_agent.runtime.checkpoint import (
|
| 19 |
+
Checkpointer,
|
| 20 |
+
InMemoryCheckpointer,
|
| 21 |
+
JSONLCheckpointer,
|
| 22 |
+
SQLiteCheckpointer,
|
| 23 |
+
)
|
| 24 |
|
| 25 |
+
__all__ = [
|
| 26 |
+
"PAEvent", "EventKind", "Visibility", "create_event", "TERMINAL_KINDS",
|
| 27 |
+
"EventBus", "parallel_merge",
|
| 28 |
+
"RunState", "RunStatus", "NodeState",
|
| 29 |
+
"Checkpointer", "InMemoryCheckpointer", "JSONLCheckpointer", "SQLiteCheckpointer",
|
| 30 |
+
]
|