Method runTask

packages/trigger-sdk/src/io.ts:1097–1399

`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.

(
    cacheKey: string | any[],
    callback: (task: ServerTask, io: IO) => Promise<T>,
    options?: RunTaskOptions & { parseOutput?: (output: unknown) => T },
    onError?: RunTaskErrorCallback
  )

   * @returns A Promise that resolves with the returned value of the callback.
   */
  async runTask<T extends Json<T> | void>(
    cacheKey: string | any[],
    callback: (task: ServerTask, io: IO) => Promise<T>,
    options?: RunTaskOptions & { parseOutput?: (output: unknown) => T },
    onError?: RunTaskErrorCallback
  ): Promise<T> {
    const parentId = this._taskStorage.getStore()?.taskId;

    if (parentId) {
      this._logger.debug("Using parent task", {
        parentId,
        cacheKey,
        options,
      });
    }

    //don't auto-yield if it's a no-op and a subtask (e.g. a log inside a task)
    const isSubtaskNoop = options?.noop === true && parentId !== undefined;
    if (!isSubtaskNoop) {
      this.#detectAutoYield("start_task", 500);
    }

    const idempotencyKey = await generateIdempotencyKey(
      [this._id, parentId ?? "", cacheKey].flat()
    );

    if (this._visitedCacheKeys.has(idempotencyKey)) {
      if (typeof cacheKey === "string") {
        throw new Error(
          `Task with cacheKey "${cacheKey}" has already been executed in this run. Each task must have a unique cacheKey.`
        );
      } else {
        throw new Error(
          `Task with cacheKey "${cacheKey.join(
            "-"
          )}" has already been executed in this run. Each task must have a unique cacheKey.`
        );
      }
    }

    this._visitedCacheKeys.add(idempotencyKey);

    const cachedTask = this._cachedTasks.get(idempotencyKey);

    if (cachedTask && cachedTask.status === "COMPLETED") {
      this._logger.debug("Using completed cached task", {
        idempotencyKey,
      });

      this._stats.cachedTaskHits++;

      return options?.parseOutput
        ? options.parseOutput(cachedTask.output)
        : (cachedTask.output as T);
    }

    if (options?.noop && this._noopTasksBloomFilter) {
      if (this._noopTasksBloomFilter.test(idempotencyKey)) {