Knowledge Platform — workers, grains and sagas¶
Generated from the architecture model
This page is rendered from model/**/*.yaml by tools/docs_model during mkdocs build. Edit the YAML, not this page; hand-written design lives on the linked service, platform and plane pages.
Workers¶
| Worker | Service | Trigger | Output events | Retry | Idempotency key | Concurrency |
|---|---|---|---|---|---|---|
| RetentionSweeper | ArtifactService | schedule 0 4 * * * |
ArtifactDeleted | fixed ×3 | artifactId |
2 by TenantId |
| ExportWorker | ArtifactService | event ProjectService.ProjectStateChanged | ArtifactStored | exponential ×5 | projectId + exportRequestId |
1 by TenantId |
| Classifier | MemoryPromotionService | event MemoryPromotionService.MemoryObserved | MemoryClassified | exponential ×5 | memoryId + classifierVersion |
4 by TenantId |
| EvidenceChecker | MemoryPromotionService | event MemoryPromotionService.MemoryClassified | — | exponential ×5 | memoryId + evidenceVersion |
2 by TenantId |
| DecaySweeper | MemoryPromotionService | schedule 0 5 * * * |
MemoryArchived, SkillCandidateProposed | fixed ×3 | memoryId + day |
2 by TenantId |
| SourceSyncScheduler | KnowledgeIngestionService | schedule */5 * * * * |
SourceSnapshotTaken, SourceStateChanged | exponential ×5 | sourceId + sourceVersion |
8 by TenantId |
| IngestionPipeline | KnowledgeIngestionService | event KnowledgeIngestionService.SourceSnapshotTaken | ChunksPublished, SnapshotFailed | exponential ×5 | snapshotId + stage |
4 by TenantId |
| DeletionPropagator | KnowledgeIngestionService | event KnowledgeIngestionService.SourceDeleted | — | exponential ×10 | lineageRef + target |
2 by TenantId |
| IndexSetBuilder | RepositoryIntelligenceService | event KnowledgeIngestionService.SourceSnapshotTaken | RepositoryIndexed, RepositoryIndexFailed | exponential ×3 | sourceId + revision + analyzerVersion |
2 by TenantId |
| IndexBuilder | VectorMemoryService | event KnowledgeIngestionService.ChunksPublished | IndexRevisionReady | exponential ×5 | indexRevisionId + chunkId |
4 by TenantId |
| GraphExtractor | VectorMemoryService | event KnowledgeIngestionService.ChunksPublished | GraphFactsUpdated | exponential ×5 | snapshotId + chunkId + extractorVersion |
2 by TenantId |
| BackendHealthProbe | VectorMemoryService | schedule */2 * * * * |
IndexDegraded, IndexRevisionReady | fixed ×2 | indexRevisionId + probeWindow |
2 by VectorProfile |
- RetentionSweeper (ArtifactService): Deletes content past the project retention window and writes deletion evidence; keeps metadata and lineage.
- ExportWorker (ArtifactService): Produces an export package (artifacts, metadata, lineage in open formats) for a project.
- Classifier (MemoryPromotionService): Classifies candidates (structured profile) into temporary, episodic, semantic candidate, procedural candidate or discard with a confidence; never promotes.
- EvidenceChecker (MemoryPromotionService): Checks semantic candidates against sources and receipts, sets the trust tier and routes to review per policy.
- DecaySweeper (MemoryPromotionService): Decays unused memories past their window, archives decayed ones and proposes reinforced procedural memories as skill candidates.
- SourceSyncScheduler (KnowledgeIngestionService): Takes snapshots per sync policy or on webhook change notifications; detects staleness.
- IngestionPipeline (KnowledgeIngestionService): Runs parse → normalize → metadata → chunk → index publish → ACL propagation for a snapshot; each stage is journaled and resumable.
- DeletionPropagator (KnowledgeIngestionService): Executes deletion lineage across chunks, vectors, graph facts, context snapshots and memory proposals within the 30-day window (D31).
- IndexSetBuilder (RepositoryIntelligenceService): Builds file tree, symbols, types, dependencies, calls, references, history, ownership, build and test relations for a snapshot using language analyzers (Roslyn for .NET first).
- IndexBuilder (VectorMemoryService): Embeds chunks through the embedding profile, writes vector and full-text items under the backend scope filter and flips the revision to Ready.
- GraphExtractor (VectorMemoryService): Entity and relationship extraction from published chunks into temporal facts with provenance (structured profile for extraction).
- BackendHealthProbe (VectorMemoryService): Probes the vector and full-text backends and marks revisions Degraded or Ready.
Grains (actors)¶
None modelled
No grains are modelled for this item yet.
Sagas¶
None modelled
No sagas are modelled for this item yet.