Primitives.org.aidigital-workers
Worker abstractions for task execution
npm install digital-workersDefine workers that process tasks from queues.
import { worker, pool } from 'digital-workers'
const reviewWorker = worker({
name: 'document-reviewer',
capabilities: [reviewDocument, extractData],
concurrency: 5,
})
const workerPool = pool({
workers: [reviewWorker, summaryWorker],
scaling: { min: 1, max: 10 },
})
await workerPool.start()Features
- Capability-based task matching
- Concurrency control
- Auto-scaling pools
- Health monitoring
- Graceful shutdown
Related
- digital-tasks — Task definitions
- ai-functions — Worker capabilities
- autonomous-agents — Agent workers
Was this page helpful?