dagster-io / dagster-cloud-cicd-action Goto Github PK

export function getProcess(parallel) {
  return parallel ? inParallel : inSeries;
}

async function inParallel(locations, processingFunction) {
  await Promise.all(Object.entries(locations).map(processingFunction));
}

async function inSeries(locations, processingFunction) {
  for (const location of locations) {
    await processingFunction(location);
  }
}

async function inSeries(locations, processingFunction) {
  for (const [locationName, location] of Object.entries(locations)) {
    await processingFunction([locationName, location]);
  }
}