Method waitForCompletion

integrations/openai/src/threads.ts:328–374

* Waits for a run to complete by polling in the background.

(
    key: IntegrationTaskKey,
    threadId: string,
    runId: string,
    options: OpenAIRequestOptions = {}
  )

   * Waits for a run to complete by polling in the background.
   */
  async waitForCompletion(
    key: IntegrationTaskKey,
    threadId: string,
    runId: string,
    options: OpenAIRequestOptions = {}
  ): Promise<OpenAI.Beta.Threads.Run> {
    return this.runTask(
      key,
      async (client, task, io) => {
        const url = createBackgroundFetchUrl(
          client,
          `/threads/${threadId}/runs/${runId}`,
          this.options.defaultQuery,
          options
        );

        const headers = this.options.defaultHeaders ?? {};

        headers["OpenAI-Beta"] = "assistants=v1";

        const completedRun = await io.backgroundPoll<OpenAI.Beta.Threads.Run>("poll", {
          url,
          requestInit: {
            headers: createBackgroundFetchHeaders(client, task.idempotencyKey, headers, options),
          },
          interval: 10,
          timeout: 600,
          responseFilter: {
            status: [200],
            body: {
              status: ["completed", "expired", "cancelled", "failed", "requires_action"],
            },
          },
        });

        return completedRun;
      },
      {
        name: "Wait for Run Completion",
        properties: [
          { label: "threadId", text: threadId },
          { label: "runId", text: runId },
        ],
      },
      handleOpenAIError
    );
  }

  /**
   * Creates a run.