Method createAndRun

integrations/openai/src/threads.ts:24–61

* Create a thread and run it in one task.

(
    key: IntegrationTaskKey,
    params: Prettify<OpenAI.Beta.ThreadCreateAndRunParams>,
    options: OpenAIRequestOptions = {}
  )

   * Create a thread and run it in one task.
   */
  async createAndRun(
    key: IntegrationTaskKey,
    params: Prettify<OpenAI.Beta.ThreadCreateAndRunParams>,
    options: OpenAIRequestOptions = {}
  ): Promise<OpenAI.Beta.Threads.Run> {
    return this.runTask(
      key,
      async (client, task) => {
        const { data, response } = await client.beta.threads
          .createAndRun(params, {
            idempotencyKey: task.idempotencyKey,
            ...options,
          })
          .withResponse();

        const outputProperties = [
          ...(createTaskOutputProperties(undefined, response.headers) ?? []),
          {
            label: "threadId",
            text: data.thread_id,
          },
          {
            label: "runId",
            text: data.id,
          },
        ];

        task.outputProperties = outputProperties;

        return data;
      },
      {
        name: "Create Thread and Run",
        params,
      },
      handleOpenAIError
    );
  }

  /**
   * Create a thread and runs it in one task, and only returns when the run is completed by polling in the background.