Method parallel

packages/trigger-sdk/src/io.ts:1042–1087

(
    cacheKey: string | any[],
    items: Array<TItem>,
    callback: (item: TItem, index: number) => Promise<T>,
    options?: Pick<RunTaskOptions, "name" | "properties">
  )

  }

  async parallel<T extends Json<T> | void, TItem>(
    cacheKey: string | any[],
    items: Array<TItem>,
    callback: (item: TItem, index: number) => Promise<T>,
    options?: Pick<RunTaskOptions, "name" | "properties">
  ): Promise<Array<T>> {
    const results = await this.runTask(
      cacheKey,
      async (task) => {
        const outcomes = await Promise.allSettled(
          items.map((item, index) => spaceOut(() => callback(item, index), index, 15))
        );

        // If all the outcomes are fulfilled, return the values
        if (outcomes.every((outcome) => outcome.status === "fulfilled")) {
          return outcomes.map(
            (outcome) => (outcome as PromiseFulfilledResult<T>).value
          ) as Array<{}>;
        }

        // If they any of the errors are non internal errors, throw the first one
        const nonInternalErrors = outcomes
          .filter((outcome) => outcome.status === "rejected" && !isTriggerError(outcome.reason))
          .map((outcome) => outcome as PromiseRejectedResult);

        if (nonInternalErrors.length > 0) {
          throw nonInternalErrors[0].reason;
        }

        // gather all the internal errors
        const internalErrors = outcomes
          .filter((outcome) => outcome.status === "rejected" && isTriggerError(outcome.reason))
          .map((outcome) => outcome as PromiseRejectedResult)
          .map((outcome) => outcome.reason as TriggerInternalError);

        throw new ResumeWithParallelTaskError(task, internalErrors);
      },
      {
        name: "parallel",
        parallel: true,
        ...(options ?? {}),
      }
    );

    return results as unknown as Array<T>;
  }

  /** `io.runTask()` allows you to run a [Task](https://trigger.dev/docs/documentation/concepts/tasks) from inside a Job run. A Task is a resumable unit of a Run that can be retried, resumed and is logged. [Integrations](https://trigger.dev/docs/integrations) use Tasks internally to perform their actions.
   *