Function: runJobs()

function runJobs<T>(
   ctx: Context, 
   jobs: T, 
options?: RunJobsOptions): JobResults<T>;

Defined in: src/jobs/runJobs.ts:262

Run multiple jobs concurrently and return all results.

Type Parameters

Type Parameter
T extends JobList

Parameters

Parameter	Type	Description
ctx	Context	Context to run the jobs in.
jobs	T	Array of jobs to run.
options?	RunJobsOptions	Concurrency and callback options.

Returns

JobResults<T>

Array of results in the same order as the jobs.

Example

Run jobs concurrently

const jobs = [
  {
    title: 'Fetch weather',
    handler: async (ctx) => {
      await wait(2000);
      return {temp: 22, city: 'Berlin'};
    },
  },
  {
    title: 'Fetch news',
    handler: async (ctx) => {
      await wait(1000);
      return {headline: 'Cat rides skateboard'};
    },
  },
];

const options = {concurrency: jobs.length, onUpdate: console.log};
const results = await runJobs(ctx, jobs, options);
console.log(results);

Run jobs sequentially with concurrency 1

const jobs = [
  {title: 'Step 1', handler: async () => 'done-1'},
  {title: 'Step 2', handler: async () => 'done-2'},
  {title: 'Step 3', handler: async () => 'done-3'},
];

const results = await runJobs(ctx, jobs, {concurrency: 1});
console.log(results);

Remarks

To keep going when a job fails, wrap the handler body in try/catch.