Method invokeAndWaitForCompletion

packages/trigger-sdk/src/job.ts:269–338

(
    cacheKey: string | string[],
    payload: TriggerInvokeType<TTrigger>,
    timeoutInSeconds: number = 60 * 60, // 1 hour
    options: Prettify<Pick<InvokeOptions, "accountId" | "context">> = {}
  )

  }

  async invokeAndWaitForCompletion(
    cacheKey: string | string[],
    payload: TriggerInvokeType<TTrigger>,
    timeoutInSeconds: number = 60 * 60, // 1 hour
    options: Prettify<Pick<InvokeOptions, "accountId" | "context">> = {}
  ): Promise<RunNotification<TOutput>> {
    const triggerClient = this.client;

    if (!triggerClient) {
      throw new Error(
        "Cannot invoke a job that is not attached to a client. Make sure you attach the job to a client before invoking it."
      );
    }

    const runStore = runLocalStorage.getStore();

    if (!runStore) {
      throw new Error(
        "Cannot invoke a job from outside of a run using invokeAndWaitForCompletion. Make sure you are running the job from within a run or use the invoke method instead."
      );
    }

    const { io, ctx } = runStore;

    return (await io.runTask(
      cacheKey,
      async (task) => {
        const parsedPayload = this.trigger.event.parseInvokePayload
          ? this.trigger.event.parseInvokePayload(payload)
            ? payload
            : undefined
          : payload;

        const result = await triggerClient.invokeJob(this.id, parsedPayload, {
          idempotencyKey: task.idempotencyKey,
          callbackUrl: task.callbackUrl ?? undefined,
          ...options,
        });

        task.outputProperties = [
          {
            label: "Run",
            text: result.id,
            url: `/orgs/${ctx.organization.slug}/projects/${ctx.project.slug}/jobs/${this.id}/runs/${result.id}/trigger`,
          },
        ];

        return {}; // we don't want to return anything here, we just want to wait for the callback
      },
      {
        name: `Manually Invoke '${this.name}' and wait for completion`,
        params: payload,
        properties: [
          {
            label: "Job",
            text: this.id,
            url: `/orgs/${ctx.organization.slug}/projects/${ctx.project.slug}/jobs/${this.id}`,
          },