Rank

Similar to MPI, each worker processing a job is identified by a unique rank. You can use this rank to do special processing for specific worker(s) if necessary. To get the rank of a worker in a map or reduce stage via context.getRank:

execution.addStage(new MapStage(async function map(x) {
  const rank = context.getRank();
  if (rank % 2 === 0) {
    // do something
  }
}));