Worker Catalog¶
The complete inventory of background workers and message consumers, grouped by platform. Workers are scaffolded from the WorkerTemplate, consume events or timers, and are exactly-once safe via an idempotency key. The canonical idempotency key format is sha256(eventId + handlerName + targetAggregateId) — see Metadata Schema. The table column shows the dominant key components for each worker. Unless noted, status is Target (final-state design).
Knowledge Platform¶
See Knowledge Platform.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| KnowledgeIngestionWorker | Knowledge | ArtifactIngested | Orchestrate ingestion pipeline | eventId + handler + artifactId | Target |
| ArtifactChunkingWorker | Knowledge | ArtifactIngested | Split artifacts into chunks | eventId + handler + artifactId | Target |
| EmbeddingWorker | Knowledge | ChunkReady | Generate vector embeddings | eventId + handler + chunkId | Target |
| EmbeddingRetryWorker | Knowledge | EmbeddingFailed | Retry failed embeddings | eventId + handler + chunkId | Target |
| EmbeddingRefreshWorker | Knowledge | Timer (scheduled) | Refresh stale embeddings | runId + handler + chunkId | Target |
| CodebaseIndexingWorker | Knowledge | RepositoryProvisioned | Index source repositories | eventId + handler + repositoryId | Target |
| CodeSymbolExtractionWorker | Knowledge | CommitCreated | Extract code symbols | eventId + handler + commitId | Target |
| CodeEmbeddingWorker | Knowledge | SymbolExtracted | Embed code symbols | eventId + handler + symbolId | Target |
| CodeDependencyGraphWorker | Knowledge | SymbolExtracted | Build dependency graph | eventId + handler + repositoryId | Target |
| DocumentationIndexingWorker | Knowledge | ArtifactIngested | Index documentation | eventId + handler + docId | Target |
| MarkdownChunkingWorker | Knowledge | DocIngested | Chunk markdown documents | eventId + handler + docId | Target |
| GraphProjectionWorker | Knowledge | ArtifactIngested | Project knowledge graph | eventId + handler + nodeId | Target |
| RuntimeSignalWorker | Knowledge | RuntimeSignalRecorded | Persist runtime signals | eventId + handler + signalId | Target |
| QualityAssessmentWorker | Knowledge | EmbeddingCompleted | Assess knowledge quality | eventId + handler + memoryId | Target |
| ClassificationWorker | Knowledge | ArtifactIngested | Classify memory records | eventId + handler + memoryId | Target |
| RedactionWorker | Knowledge | DataClassified | Redact sensitive content | eventId + handler + memoryId | Target |
| RetentionWorker | Knowledge | Timer (scheduled) | Enforce retention policy | runId + handler + memoryId | Target |
| StaleMemoryWorker | Knowledge | Timer (scheduled) | Flag stale memory | runId + handler + memoryId | Target |
| ConflictDetectionWorker | Knowledge | EmbeddingCompleted | Detect conflicting knowledge | eventId + handler + memoryId | Target |
| KnowledgeReplayWorker | Knowledge | ReplayRequested | Replay knowledge events | eventId + handler + projectionId | Target |
Control Plane¶
See Control Plane.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| WorkflowTimeoutWorker | Control Plane | Timer (scheduled) | Time out stalled workflows | runId + handler + workflowInstanceId | Target |
| TaskAssignmentWorker | Control Plane | WorkflowInstanceStarted | Assign agent tasks | eventId + handler + agentTaskId | Target |
| ProcessStateProjectionWorker | Control Plane | AgentTaskCompleted | Project durable process state | eventId + handler + workflowInstanceId | Target |
| QuotaEnforcementWorker | Control Plane | UsageRecorded | Enforce tenant quotas | eventId + handler + tenantId | Target |
| UsageRollupWorker | Control Plane | Timer (scheduled) | Roll up usage records | runId + handler + tenantId | Target |
| AuditExportWorker | Control Plane | Timer (scheduled) | Export audit entries | runId + handler + tenantId | Target |
| BlueprintValidationWorker | Control Plane | BlueprintSubmitted | Validate blueprints | eventId + handler + blueprintId | Target |
| DependencyResolutionWorker | Control Plane | ProjectCreated | Resolve module dependencies | eventId + handler + projectId | Target |
| WorkflowReplayWorker | Control Plane | ReplayRequested | Replay workflow events | eventId + handler + workflowInstanceId | Target |
Agent Mesh¶
See Agent Mesh.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| AgentTaskDispatchWorker | Agent Mesh | AgentTaskAssigned | Dispatch tasks to runtime | eventId + handler + agentTaskId | Target |
| ExecutionTimeoutWorker | Agent Mesh | Timer (scheduled) | Time out hung executions | runId + handler + executionId | Target |
| CorrectionRetryWorker | Agent Mesh | ValidationFailed | Retry self-correction | eventId + handler + executionId | Target |
| ModelInvocationWorker | Agent Mesh | ModelInvocationRequested | Invoke models | eventId + handler + invocationId | Target |
| ToolInvocationWorker | Agent Mesh | ToolInvocationRequested | Invoke MCP/tools | eventId + handler + invocationId | Target |
| AgentHealthProbeWorker | Agent Mesh | Timer (scheduled) | Probe agent health | runId + handler + agentId | Target |
| TelemetryFlushWorker | Agent Mesh | Timer (scheduled) | Flush execution telemetry | runId + handler + executionId | Target |
| PoisonTaskWorker | Agent Mesh | DeadLetter | Quarantine poison tasks | eventId + handler + agentTaskId | Target |
Template & Library Platform¶
See Template & Library.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| TemplateValidationWorker | Template & Library | TemplateVersionCreated | Validate templates | eventId + handler + templateVersionId | Target |
| TemplateScaffoldWorker | Template & Library | TemplateExecuted | Generate scaffolds | eventId + handler + executionId | Target |
| TemplateCompatibilityWorker | Template & Library | TemplateVersionCreated | Evaluate compatibility | eventId + handler + templateVersionId | Target |
| TemplateUpgradeWorker | Template & Library | UpgradeRequested | Build upgrade plans | eventId + handler + templateId | Target |
| LibraryIndexingWorker | Template & Library | LibraryPublished | Index library packages | eventId + handler + libraryVersionId | Target |
| DependencyScanWorker | Template & Library | LibraryPublished | Scan dependencies | eventId + handler + libraryVersionId | Target |
| PackagePublishWorker | Template & Library | LibraryPublished | Publish packages | eventId + handler + packageId | Target |
DevOps / GitOps¶
See DevOps / GitOps.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| RepositoryProvisioningWorker | DevOps | RepositoryRequested | Provision repositories | eventId + handler + repositoryId | Target |
| CommitWorker | DevOps | CommitRequested | Compose and push commits | eventId + handler + commitId | Target |
| PullRequestWorker | DevOps | PullRequestRequested | Open pull requests | eventId + handler + pullRequestId | Target |
| PipelineGenerationWorker | DevOps | RepositoryProvisioned | Generate pipelines | eventId + handler + repositoryId | Target |
| PipelineMonitorWorker | DevOps | PipelineRunStarted | Monitor pipeline runs | eventId + handler + pipelineRunId | Target |
| BuildResultIngestionWorker | DevOps | BuildCompleted | Ingest build results | eventId + handler + buildResultId | Target |
| ReleaseOrchestrationWorker | DevOps | ReleaseApproved | Orchestrate releases | eventId + handler + releaseId | Target |
| IaCProvisioningWorker | DevOps | InfrastructureRequested | Run Pulumi provisioning | eventId + handler + planId | Target |
| GitOpsSyncWorker | DevOps | GitOpsSyncRequested | Reconcile GitOps state | eventId + handler + syncStateId | Target |
| ContainerBuildWorker | DevOps | BuildCompleted | Build container images | eventId + handler + imageId | Target |
| PackagePublishingWorker | DevOps | BuildCompleted | Publish packages | eventId + handler + packageId | Target |
Runtime Cloud¶
See Runtime Cloud.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| RuntimeDeploymentWorker | Runtime Cloud | DeploymentPromoted | Execute runtime deployments | eventId + handler + deploymentId | Target |
| RuntimeHealthWorker | Runtime Cloud | Timer (scheduled) | Probe runtime health | runId + handler + serviceId | Target |
| ScalingPolicyWorker | Runtime Cloud | HealthCheckCompleted | Apply scaling policies | eventId + handler + scalingPolicyId | Target |
| DriftDetectionWorker | Runtime Cloud | Timer (scheduled) | Detect configuration drift | runId + handler + environmentId | Target |
| ConfigurationSyncWorker | Runtime Cloud | ConfigurationChanged | Sync configuration | eventId + handler + configurationId | Target |
| SecretRotationWorker | Runtime Cloud | Timer (scheduled) | Rotate secret bindings | runId + handler + secretBindingId | Target |
| RuntimeInventoryWorker | Runtime Cloud | RuntimeDeploymentCompleted | Reconcile service inventory | eventId + handler + serviceId | Target |
Observability & Feedback¶
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| TraceIngestionWorker | Observability | TraceRecorded | Ingest distributed traces | eventId + handler + traceId | Target |
| MetricAggregationWorker | Observability | Timer (scheduled) | Aggregate metric series | runId + handler + metricSeriesId | Target |
| AlertEvaluationWorker | Observability | MetricAggregated | Evaluate alert rules | eventId + handler + alertRuleId | Target |
| IncidentAnalysisWorker | Observability | IncidentOpened | Run root-cause analysis | eventId + handler + incidentId | Target |
| FeedbackCreationWorker | Observability | RuntimeSignalRecorded | Create feedback items | eventId + handler + feedbackItemId | Target |
| QualityScoreWorker | Observability | BuildCompleted | Compute quality scores | eventId + handler + projectId | Target |
| CostAnomalyWorker | Observability | UsageRecorded | Detect cost anomalies | eventId + handler + projectId | Target |
| TelemetryCorrelationWorker | Observability | TraceRecorded | Correlate telemetry | eventId + handler + correlationId | Target |
Governance / Security / Compliance¶
See Governance.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| PolicyEvaluationWorker | Governance | PolicyEvaluationRequested | Evaluate policies | eventId + handler + policyDecisionId | Target |
| ApprovalTimeoutWorker | Governance | Timer (scheduled) | Time out approvals | runId + handler + approvalRequestId | Target |
| AuditExportWorker | Governance | Timer (scheduled) | Export audit entries | runId + handler + tenantId | Target |
| ComplianceReportWorker | Governance | ReportRequested | Generate compliance reports | eventId + handler + reportId | Target |
| SecurityScanIngestionWorker | Governance | ScanCompleted | Ingest security scans | eventId + handler + findingId | Target |
| RiskScoreWorker | Governance | SecurityFindingRaised | Compute risk scores | eventId + handler + riskScoreId | Target |
| DataClassificationWorker | Governance | ArtifactIngested | Classify data | eventId + handler + classificationId | Target |
| SecretScanWorker | Governance | CommitCreated | Scan for secret leaks | eventId + handler + commitId | Target |
Marketplace¶
See Marketplace.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| AssetIndexingWorker | Marketplace | AssetPublished | Index marketplace assets | eventId + handler + assetVersionId | Target |
| CompatibilityEvaluationWorker | Marketplace | AssetVersionReleased | Evaluate compatibility | eventId + handler + assetVersionId | Target |
| InstallationWorker | Marketplace | AssetInstalled | Execute installations | eventId + handler + installationId | Target |
| AssetQualityScanWorker | Marketplace | AssetPublished | Scan asset quality | eventId + handler + assetVersionId | Target |
| MarketplacePublishingWorker | Marketplace | AssetPublished | Publish to catalog | eventId + handler + assetId | Target |
Integration Platform¶
See Integration Platform.
| Worker | Platform | Trigger | Purpose | Idempotency Key | Status |
|---|---|---|---|---|---|
| WebhookDeliveryWorker | Integration | WebhookSubscribed | Deliver webhooks | eventId + handler + deliveryId | Target |
| IntegrationSyncWorker | Integration | IntegrationConnectionEstablished | Sync external systems | eventId + handler + connectionId | Target |
| CredentialRotationWorker | Integration | Timer (scheduled) | Rotate credentials | runId + handler + credentialId | Target |
| ExternalApiHealthWorker | Integration | Timer (scheduled) | Probe external API health | runId + handler + clientId | Target |
| IntegrationRetryWorker | Integration | IntegrationFailed | Retry failed integrations | eventId + handler + runId | Target |