1// queue.ts — agentic job runner

2import { RateLimiter } from "./rate-limiter"

3import { spans } from "@/lib/tracing"

4

5export async function processQueue(jobs: Job[]) {

6 const limiter = new RateLimiter({ rps: 12 })

7 const results = await Promise.all(

8 jobs.map(async (job) => {

9 return await limiter.acquire().then(()=>

10 spans("job.run", ()=> job.run())

11 ).catch((err) => logger.error({ jobId: job.id, err }))

12 })

13 )

14 return results

15}