-
Notifications
You must be signed in to change notification settings - Fork 0
feat: implement centralized single-writer state coordination (TaskEngine) #204
Copy link
Copy link
Closed
Labels
prio:highImportant, should be prioritizedImportant, should be prioritizedscope:large3+ days of work3+ days of workspec:agent-systemDESIGN_SPEC Section 3 - Agent SystemDESIGN_SPEC Section 3 - Agent Systemspec:architectureDESIGN_SPEC Section 15 - Technical ArchitectureDESIGN_SPEC Section 15 - Technical Architecturespec:communicationDESIGN_SPEC Section 5 - Communication ArchitectureDESIGN_SPEC Section 5 - Communication Architecturespec:task-workflowDESIGN_SPEC Section 6 - Task & Workflow EngineDESIGN_SPEC Section 6 - Task & Workflow Enginetype:featureNew feature implementationNew feature implementation
Description
Summary
The spec describes a centralized single-writer pattern where a TaskEngine owns all task/project mutations via asyncio.Queue. Agents submit requests, the engine applies model_copy(update=...) sequentially and publishes snapshots. Not implemented.
Design Spec Reference
- §6.8 State Coordination vs Workspace Isolation (table)
- §15.5 Engineering Conventions — "State coordination" row
Scope
TaskEnginesingle-writer service withasyncio.Queue- Sequential mutation application via
model_copy(update=...) - Snapshot publishing for consumers
- Optional
version: intfield on state models for future optimistic concurrency
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
prio:highImportant, should be prioritizedImportant, should be prioritizedscope:large3+ days of work3+ days of workspec:agent-systemDESIGN_SPEC Section 3 - Agent SystemDESIGN_SPEC Section 3 - Agent Systemspec:architectureDESIGN_SPEC Section 15 - Technical ArchitectureDESIGN_SPEC Section 15 - Technical Architecturespec:communicationDESIGN_SPEC Section 5 - Communication ArchitectureDESIGN_SPEC Section 5 - Communication Architecturespec:task-workflowDESIGN_SPEC Section 6 - Task & Workflow EngineDESIGN_SPEC Section 6 - Task & Workflow Enginetype:featureNew feature implementationNew feature implementation