Your AI creative studio.
All in one place.

export class JobQueue<T> {
  constructor(private concurrency = 4) {}

  async run(jobs: Job<T>[], signal?: AbortSignal) {
    signal?.throwIfAborted();
    const workers = chunk(jobs, this.concurrency)
      .map(batch => runWorker(batch, { signal }));
    return await Promise.allSettled(workers);
  }
}

export async function withRetry<T>(task: () => Promise<T>) {
  for (let attempt = 0; attempt < 4; attempt++) {
    try { return await task(); }
    catch (error) {
      await delay(250 * 2 ** attempt);
    }
  }
  throw new RetryLimitError();
}

it('honors concurrency and retries failures', async () => {
  const queue = new JobQueue(3);
  const results = await queue.run(jobs);
  expect(maxActive).toBeLessThanOrEqual(3);
  expect(results).toHaveLength(jobs.length);
});