Task Queue Kit
Distributed task queuing with priority and dead-letter handling.
Configuration
Task Queue
Active
8
Queued
42
Failed
1
Worker 1BUSYProcessing task-42
Worker 2IDLEWaiting for work
Worker 3BUSYProcessing task-43
Queue42 tasksPriority ordered
Integration Code
import { createDistributed } from 'agent-tools-kit/distributed'
const pool = createDistributed({ type: 'worker-pool', autoScale: true })
await pool.start()
await pool.enqueue({ task: 'process', data: {} })