Worker catalog

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.

Name	Kind	Platform	Service	Trigger / key	Idempotency	Summary
ClosureResolver	worker	Control Plane	AgentRegistryService	event	releaseId + sourceCommit	Resolves a candidate's dependency closure from Git and the registry, computes hashes and stores the manifest.
ReconciliationWorker	worker	Control Plane	CostUsageService	schedule	usageId + statementRef	Confirms estimated and uncertain usage from provider statements and late receipts; emits UsageReconciled.
ReservationExpiryWorker	worker	Control Plane	CostUsageService	schedule	reservationId + expiresAt	Expires reservations whose run never dispatched and releases committed amounts.
InvoicingWorker	worker	Control Plane	FactoryCommercialService	schedule	subscriptionId + periodEnd	Closes a period, snapshots reconciled usage and seat counts, issues the invoice through the SaaS Billing template.
DelegationExpiryReconciler	worker	Control Plane	ProjectService	schedule	delegationId + expiresAt	Expires delegations past expiresAt and emits DelegationChanged.
ProjectOffboardingWorker	worker	Control Plane	ProjectService	event	projectId + Closing	Runs the Closing procedure: cancels open runs through Run Control, revokes delegations, triggers export or deletion (XL-13, XL-14) and completes to Closed.
LeaseExpiryReconciler	worker	Control Plane	RunControlService	schedule	leaseId + fencingToken	Expires overdue leases, marks attempts TimedOut (or Uncertain when a side effect may have happened) and schedules the retry or terminal failure.
ApprovalExpiryReconciler	worker	Control Plane	RunControlService	schedule	approvalId + version	Moves pending approvals past expiresAt to Expired and fails or re-requests per policy.
RunDispatcher	worker	Control Plane	RunControlService	event	stepId + attempt number	Selects the next Pending step of Running runs and dispatches an attempt with a new lease when capacity (BC-26) allows.
RunGrain	grain	Control Plane	RunControlService	runId	—	Serialises all transitions of one run; holds the in-memory copy of state and version and enlists the outbox writer in the same NHibernate transaction.
LeaseHeartbeat	worker	Agent Mesh	AgentRuntimeService	timer	leaseId + renewalSequence	Renews the lease of every running attempt before expiry through Run Control; a failed renewal pauses the attempt at its next checkpoint.
OrphanedAttemptReconciler	worker	Agent Mesh	AgentRuntimeService	schedule	attemptId + outcomeHash	Finds attempts whose grain is inactive and whose lease is gone; settles them as Uncertain when a call was in flight, otherwise Cancelled, and reports.
CheckpointCompactor	worker	Agent Mesh	AgentRuntimeService	schedule	checkpointId	Deletes superseded adapter checkpoints of terminal attempts after the retention window, keeping the last one and every checkpoint referenced by evidence.
ReleaseCacheWarmer	worker	Agent Mesh	AgentRuntimeService	event	releaseId + adapterVersion	Verifies newly published releases against this worker's adapter before the first dispatch.
AttemptGrain	grain	Agent Mesh	AgentRuntimeService	attemptId	—	Serialises the loop of one attempt; holds the adapter session, writes checkpoints, enforces the fencing token and the limits, and reports the outcome once.
TimerScheduler	worker	Agent Mesh	WorkflowEngineService	reminder	timerId	Registers an Orleans reminder for every timer entry and applies the fired timer to the run.
StuckRunReconciler	worker	Agent Mesh	WorkflowEngineService	schedule	stepRunId + lastOutcomeSequence	Finds workflow runs whose active step runs have no corresponding open attempt or approval in Run Control and re-emits StepReady or fails the step per policy.
DefinitionCacheWarmer	worker	Agent Mesh	WorkflowEngineService	event	releaseId	Validates and caches newly published workflow definitions.
WorkflowRunGrain	grain	Agent Mesh	WorkflowEngineService	runId	—	Serialises Advance for one run, holds the cursor and active step runs, registers timer reminders and commits step-run rows with the outbox in one transaction.
UtilizationCollector	worker	Model & Compute Platform	ComputePoolService	schedule	poolId + minute	Marks pools whose utilization report is older than the staleness window as not placeable and refreshes cold-start estimates from observed loads.
WarmKeeper	worker	Model & Compute Platform	ComputePoolService	schedule	poolId + model + window	Keeps the models of profiles with warm-keep policy loaded on their pools and evicts models unused beyond the idle window.
PoolGrain	grain	Model & Compute Platform	ComputePoolService	poolId	—	Serialises placements and cache updates of one pool so that capacity is never double-booked.
DeploymentHealthProbe	worker	Model & Compute Platform	ModelRouterService	schedule	deploymentId + probeWindow	Probes every Approved deployment with a minimal request and marks it Degraded or Approved; records latency.
ReceiptReconciler	worker	Model & Compute Platform	ModelRouterService	schedule	invocationId + statementRef	Confirms receipts with usage Unknown or Estimated from provider statements and forwards the correction to Usage Accounting.
CapabilityEvidenceImporter	worker	Model & Compute Platform	ModelRouterService	event	deploymentId + suiteVersion + evidenceRef	Imports evaluation records of the capability suite into deployment scores and moves Candidate deployments to Evaluated.
RetentionSweeper	worker	Knowledge Platform	ArtifactService	schedule	artifactId	Deletes content past the project retention window and writes deletion evidence; keeps metadata and lineage.
ExportWorker	worker	Knowledge Platform	ArtifactService	event	projectId + exportRequestId	Produces an export package (artifacts, metadata, lineage in open formats) for a project.
Classifier	worker	Knowledge Platform	MemoryPromotionService	event	memoryId + classifierVersion	Classifies candidates (structured profile) into temporary, episodic, semantic candidate, procedural candidate or discard with a confidence; never promotes.
EvidenceChecker	worker	Knowledge Platform	MemoryPromotionService	event	memoryId + evidenceVersion	Checks semantic candidates against sources and receipts, sets the trust tier and routes to review per policy.
DecaySweeper	worker	Knowledge Platform	MemoryPromotionService	schedule	memoryId + day	Decays unused memories past their window, archives decayed ones and proposes reinforced procedural memories as skill candidates.
SourceSyncScheduler	worker	Knowledge Platform	KnowledgeIngestionService	schedule	sourceId + sourceVersion	Takes snapshots per sync policy or on webhook change notifications; detects staleness.
IngestionPipeline	worker	Knowledge Platform	KnowledgeIngestionService	event	snapshotId + stage	Runs parse → normalize → metadata → chunk → index publish → ACL propagation for a snapshot; each stage is journaled and resumable.
DeletionPropagator	worker	Knowledge Platform	KnowledgeIngestionService	event	lineageRef + target	Executes deletion lineage across chunks, vectors, graph facts, context snapshots and memory proposals within the 30-day window (D31).
IndexSetBuilder	worker	Knowledge Platform	RepositoryIntelligenceService	event	sourceId + revision + analyzerVersion	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	worker	Knowledge Platform	VectorMemoryService	event	indexRevisionId + chunkId	Embeds chunks through the embedding profile, writes vector and full-text items under the backend scope filter and flips the revision to Ready.
GraphExtractor	worker	Knowledge Platform	VectorMemoryService	event	snapshotId + chunkId + extractorVersion	Entity and relationship extraction from published chunks into temporal facts with provenance (structured profile for extraction).
BackendHealthProbe	worker	Knowledge Platform	VectorMemoryService	schedule	indexRevisionId + probeWindow	Probes the vector and full-text backends and marks revisions Degraded or Ready.
HandshakeProbe	worker	Tools & MCP Platform	McpServerRegistryService	schedule	serverId + probeWindow	Performs the MCP initialize handshake against every Active server and tracks protocol version and health.
CapabilityDiscovery	worker	Tools & MCP Platform	McpServerRegistryService	event	serverId + capabilityHash	Lists tools, resources and prompts after registration or on schema change and refreshes bindings; new or changed schemas unbind until re-approved.
UncertainEffectReconciler	worker	Tools & MCP Platform	ToolAdapterService	schedule	invocationId + state	Finds Executing invocations whose grain is inactive or whose sandbox lease expired and settles them as Uncertain (or Failed when no effect was possible), notifying the runtime.
SandboxReaper	worker	Tools & MCP Platform	ToolAdapterService	schedule	leaseId	Releases sandboxes and workspaces whose invocation ended or whose lease expired; reports to Execution Capacity.
DescriptorHealthProbe	worker	Tools & MCP Platform	ToolAdapterService	schedule	toolId + version + probeWindow	Probes native and MCP tools (handshake, schema fetch) and marks descriptors healthy or unhealthy.
ToolInvocationGrain	grain	Tools & MCP Platform	ToolAdapterService	invocationId	—	Serialises the pipeline of one invocation, holds the sandbox lease and the fencing token, streams progress and enforces the timeout reminder.
OutboundDeliveryRetrier	worker	Integration Platform	ConnectorRegistryService	schedule	deliveryId + attempts	Retries failed outbound deliveries per the connector's retry profile within the calling tool's budget; final failure emits DeliveryFailed.
InboundDispatcher	worker	Integration Platform	ConnectorRegistryService	event	dedupKey	Dispatches verified inbound deliveries to workflow triggers, knowledge sync or fleet signals and acknowledges.
ConformanceRunner	worker	Integration Platform	ConnectorRegistryService	manual	connectorId + version + suiteVersion	Runs the connector conformance suite (capability calls against a sandbox connection) and records certification evidence.
ConnectionHealthProbe	worker	Integration Platform	IntegrationService	schedule	connectionId + probeWindow	Probes Active connections with a read-only provider call through brokered credentials and marks Degraded or Active.
RotationReminder	worker	Integration Platform	IntegrationService	schedule	connectionId + day	Raises Studio tasks and audit events for connections whose rotation is due or whose grants expire.
ExpiryAndSeatSweeper	worker	Marketplace	LicenseService	schedule	entitlementId + day	Expires entitlements past validity and reconciles seat counts with installations.
RevenueShareReporter	worker	Marketplace	LicenseService	schedule	publisherId + month	Produces publisher revenue-share statements from the Factory's reconciled usage and invoices.
Indexer	worker	Marketplace	MarketplaceCatalogService	event	listingId + version	Maintains the search index of listings (text, kind, compatibility, publisher, rating) from listing events.
UpdateOfferer	worker	Marketplace	MarketplaceCatalogService	event	installationId + releaseId	Offers installation updates when a listing points to a newer release; applies them automatically only where the installing tenant's policy allows.
GateEvaluator	worker	DevOps / GitOps	EnvironmentPromotionService	event	promotionId + gateKind	Evaluates gates in order (pipeline results, policy, prior environment, environment ready, evaluation evidence where the product release carries agent-generated assets) and requests the approval when the environment class demands it.
Verifier	worker	DevOps / GitOps	EnvironmentPromotionService	event	promotionId	Runs post-deploy verification (health, smoke suite from the pipeline, SLO window) and completes or auto-rolls back per strategy.
PromotionSaga	saga	DevOps / GitOps	EnvironmentPromotionService	promotionId	—	Gates → approval (production) → desired state to provisioning → apply → verify → complete, with rollback to the previous release as compensation after a failed verification.
DeliveryApplier	worker	DevOps / GitOps	PipelineExecutionService	event	deliveryId	Maps verified inbound deliveries (push, pull request, review, pipeline run) to proposal and run state; unknown references are looked up through the connector.
RunReconciler	worker	DevOps / GitOps	PipelineExecutionService	schedule	pipelineRunId + window	Polls runs still Running past their expected duration and proposals without a terminal state through the connector (read class).
PublicationVerifier	worker	DevOps / GitOps	ReleaseService	event	releaseId + componentName	Checks each component's feed or registry for the digest (through the existing CI publishing evidence and registry reads) and records publication evidence; moves the release to Released when complete.
ReleaseNotesWriter	worker	DevOps / GitOps	ReleaseService	event	releaseId	Drafts release notes from merged proposals and results with the structured profile and stores them as an artifact (never auto-published).
Planner	worker	Runtime Cloud	IaCProvisioningService	event	provisioningRunId + plan	Resolves the program version, configuration and secret references and runs the IaC planner; records the plan receipt; routes to approval when required.
Applier	worker	Runtime Cloud	IaCProvisioningService	event	provisioningRunId + apply	Runs the IaC apply for approved or allowed runs with the runner's workload identity; records outputs and logs as artifacts; reports applied or failed.
GitOpsReconciler	worker	Runtime Cloud	IaCProvisioningService	schedule	environmentId + window	Re-plans the declared specification of every environment on a schedule; applies non-destructive differences automatically where policy allows, and turns destructive or production differences into reconciliation proposals.
Autoscaler	worker	Runtime Cloud	ExecutionCapacityService	schedule	poolId + window	Adjusts pool sizes within bounds from utilisation and queued leases; size changes go through provisioning.
LeaseExpirer	worker	Runtime Cloud	ExecutionCapacityService	schedule	leaseId + expiry	Expires leases whose heartbeat stopped and frees their capacity.
PoolGrain	grain	Runtime Cloud	ExecutionCapacityService	poolId	—	Serialises lease grants per pool so capacity accounting is exact under concurrency; drains the queue as capacity frees.
Observer	worker	Runtime Cloud	RuntimeEnvironmentService	schedule	environmentId + observation window	Reads clusters and cloud APIs for every environment, updates the inventory, marks stale environments, and resolves findings no longer observed.
DriftComparer	worker	Runtime Cloud	RuntimeEnvironmentService	event	environmentId + observedAt	Compares each observation with the declared specification, raises findings and groups them into proposals (auto-accepting non-destructive ones outside production where policy allows).
Pager	worker	Product Fleet Operations	FleetIncidentService	event	incidentId + escalationLevel	Pages the on-call responder for Sev1 and Sev2 through the paging connector and escalates after the edition's acknowledgement target.
CustomerNotifier	worker	Product Fleet Operations	FleetIncidentService	event	incidentId + state + customerTenantId	Sends customer notifications for opened, mitigated and resolved incidents through the product owner's chosen connectors, recording receipts.
OnCallGapChecker	worker	Product Fleet Operations	FleetIncidentService	schedule	hour	Alerts when a ManagedPlus product has no on-call coverage in the coming window.
OffboardingSaga	saga	Product Fleet Operations	FleetIncidentService	offboardingId	—	Request → approval → export order → customer handover acknowledgement → deletion order → completion evidence; cancellation is possible until deletion starts.
ProductHealthProbe	worker	Product Fleet Operations	FleetInventoryService	schedule	instanceId + window	Calls each instance's health endpoint through its product gateway (GW-07) and the HealthChecks aggregator; updates health and staleness.
WaveDriver	worker	Product Fleet Operations	FleetRolloutService	event	rolloutId + wave	Requests the promotions of the current wave, waits for their completion, runs the bake timer against the guards, and advances, halts or completes.
ReScaffoldRequester	worker	Product Fleet Operations	FleetRolloutService	event	productId + targetAssetReleaseId	For template upgrades, submits a Factory run that regenerates the product with the new template release (through Run Control) and waits for its release to be ready before planning the rollout.
RolloutSaga	saga	Product Fleet Operations	FleetRolloutService	rolloutId	—	Plan → approval (production waves) → per wave: promotions → bake against guards → next wave; a breach or failed promotion halts, rolls the wave back and waits for the Operator.
ModelSync	worker	Data & Event Platform	EnvelopeRegistryService	manual	topic + schemaVersion	Applies the topics, producers, consumers and schema references of the architecture model (the generated catalogs) to the registry at release time and reports drift.
DeprecationSweeper	worker	Data & Event Platform	EnvelopeRegistryService	schedule	topic + day	Retires topics whose deprecation window elapsed.
BindingReconciler	worker	Data & Event Platform	StoreProfileService	schedule	storeId + window	Compares bindings with the observed state from provisioning and flags drift (missing schema, wrong region, key rotation overdue).
RetentionSweeper	worker	Data & Event Platform	RetentionResidencyService	schedule	ruleId + day	Computes expiry per rule and issues purge tasks to owning services (delete, redact or archive) with receipts.
OrderDispatcher	worker	Data & Event Platform	RetentionResidencyService	event	orderId + ownerService	Fans an order out to every owning service as tasks, tracks acknowledgements and marks orders Completed or Overdue.
Exporter	worker	Data & Event Platform	RetentionResidencyService	event	orderId	Collects export bundles from owning services into one archive with a manifest in open formats.
TenantDeletionSaga	saga	Data & Event Platform	RetentionResidencyService	orderId	—	Approval, order, tasks to every owner in dependency order (projections and indexes first, artifacts, then authoritative stores, audit redacted last), acknowledgements, completion evidence; a failing owner stops the rest and leaves the order Overdue.
EvidenceWriter	worker	Governance	AuditService	event	sourceEvent + eventId	Appends consumed events as evidence entries in tenant sequence with the hash chain and mirrors them to the immutable store.
ChainVerifier	worker	Governance	AuditService	schedule	tenantId + day	Re-computes and verifies each tenant's hash chain since the last signed head, signs the new head and raises a Critical finding on a break.
RetentionAndRedactionSweeper	worker	Governance	AuditService	schedule	entryId	Redacts personal identifiers in evidence past the project retention window while keeping the chain verifiable; enforces classification retention across stores by emitting lifecycle tasks.
ExportWorker	worker	Governance	AuditService	manual	projectId + exportRequestId	Produces an export package of a project's evidence with chain proofs in open formats.
DecisionRetentionSweeper	worker	Governance	PolicyEngineService	schedule	decisionId	Moves decisions older than the hot window to the immutable audit store and keeps the 7-year evidence copy.
ExpirySweeper	worker	Governance	SecretBrokerService	schedule	issuanceId	Marks expired issuances and revokes at providers that support revocation.
RotationScheduler	worker	Governance	SecretBrokerService	schedule	referenceId + day	Raises rotation tasks for references past their rotation period and auto-rotates kinds the vault can rotate.
MetricRuleEvaluator	worker	Observability	AlertRuleService	schedule	ruleId + minute	Evaluates metric-threshold rules against the backend on a schedule and fires or resolves instances.
Notifier	worker	Observability	AlertRuleService	event	alertId + route	Delivers notifications for fired alerts through the Studio and connectors with receipts.
ProjectionRebuilder	worker	Observability	DashboardService	manual	runId + lastEventSequence	Rebuilds run projections from Run Control's journal and producers' events after a restore or on request.
OverviewAggregator	worker	Observability	DashboardService	schedule	tenantId + window + computedAt	Recomputes overview metrics per subject and window from run projections.
ProposalGenerator	worker	Observability	FeedbackService	schedule	targetAssetId + evidenceHash	Clusters feedback, drift and failed evaluations per asset and drafts proposals with evidence and an expected effect (structured profile); never applies anything.
DatasetSnapshotter	worker	Observability	FeedbackService	manual	datasetId + version	Builds dataset snapshots from harvested tasks and curated additions and stores them as artifacts.
SuiteRunner	worker	Observability	QualityScoreService	event	evaluationId + taskId	Executes the tasks of a suite as Factory runs under the evaluation project, collects per-task metrics and computes the verdict against thresholds and the baseline.
DriftMonitor	worker	Observability	QualityScoreService	schedule	targetReleaseId + window	Compares production outcome statistics per release with its evaluated scores and raises drift.
SloEvaluator	worker	Observability	SloService	schedule	sloId + window	Evaluates every active objective from projections and metrics, computes burn rates and emits breaches and recoveries.
HealthCollector	worker	Observability	SloService	schedule	hostId + minute	Collects host health from the HealthChecks aggregator and the hosts' probes and updates the rollup.
SessionSweeper	worker	Factory Studio	StudioBff	schedule	sessionId	Expires idle sessions and releases their realtime subscriptions.
FanOut	worker	Factory Studio	StudioNotificationService	event	eventId + userId	Resolves recipients per event through the owning platform's permission check and the users' preferences, creates notifications and dispatches email and chat deliveries through connectors.
Digester	worker	Factory Studio	StudioNotificationService	schedule	userId + window	Builds hourly or daily digests for users who chose them.
StreamBridge	worker	Factory Studio	StudioRealtimeGateway	event	subscriptionId + sequence	Holds the upstream gRPC streams (operations projections per scope) and fans them out to subscribed connections with per-connection buffers and backpressure.
Validator	worker	Template & Library	BlueprintService	event	blueprintId + version + documentHash	Runs schema validation and the kind's rule set, derives the context map and domain model for service and module kinds, and writes the report as an artifact.
PlanProposer	worker	Template & Library	GenerationRecipeService	event	blueprintId + blueprintVersion	Proposes a module plan from the context map and domain model (one microservice per context, a gateway, a shell and MFEs per UI blueprint, libraries per shared kernel) using Published template versions and the structured profile for naming.
RecipeValidator	worker	Template & Library	GenerationRecipeService	manual	recipeId + version + hash	Validates module entries against manifests and switches and every pinned library against the matrix with evidence.
Discoverer	worker	Template & Library	TemplateRegistryService	schedule	repository + commit	Reads .template.config, project files, switches, pipelines and docs from every template repository (through connectors) and package versions from the feeds; pins manifests by hash.
CompatibilityComputer	worker	Template & Library	TemplateRegistryService	event	cell + evidence	Computes matrix cells from manifests, package references, build evidence and conformance runs; marks cells Unknown where evidence is missing.
UsageMeter	worker	Generated SaaS	GeneratedSaasFoundations	schedule	subscriptionId + dimension + period	Aggregates metered events per dimension and period (the Metering template) and emits period totals.
DescriptorPublisher	worker	Generated SaaS	GeneratedProductHost	manual	productId + releaseId	Publishes the descriptor at start-up and after every deployment so the fleet sees the running release and provenance.