@pmcollab/coworkstream-jobs

Job queue adapters for @pmcollab/coworkstream-engine. Push agent dispatch out-of-band so the HTTP request returns immediately.

Install

npm install @pmcollab/coworkstream-jobs
# pick one of:
npm install bullmq ioredis
npm install inngest
npm install @trigger.dev/sdk

Use (BullMQ)

import { Redis } from 'ioredis'
import { createBullMQQueue } from '@pmcollab/coworkstream-jobs'

const connection = new Redis(process.env.REDIS_URL)
const queue = createBullMQQueue({ connection })

// web tier
await queue.enqueue(item)

// worker
await queue.consume(async (item) => {
  await engine.process(item)
})

Adapters

| Adapter | Backend | |---|---| | createMemoryQueue() | In-process (tests, dev) | | createBullMQQueue({ connection }) | BullMQ on Redis | | createInngestQueue({ inngest }) | Inngest | | createTriggerQueue({ tasks }) | Trigger.dev v3 |

All adapters expose the same { enqueue, consume } interface so engine wiring code is portable.

License

Commercial. See LICENSE in the repository root.