Edits history of script submission #928 for ' run flow by path and wait until completion in openai format (windmill)'

  • nativets
    One script reply has been approved by the moderators
    Ap­pro­ved
    /**
     * run flow by path and wait until completion in openai format
     *
     */
    export async function main(
      workspace: string,
      path: string,
      include_header: string | undefined,
      queue_limit: string | undefined,
      job_id: string | undefined,
      body: { [k: string]: unknown }
    ) {
      const url = new URL(
        `${BASE_URL}/api/w/${workspace}/jobs/openai_sync/f/${path}`
      );
      for (const [k, v] of [
        ["include_header", include_header],
        ["queue_limit", queue_limit],
        ["job_id", job_id],
      ]) {
        if (v !== undefined && v !== "") {
          url.searchParams.append(k, v);
        }
      }
      const response = await fetch(url, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          Authorization: "Bearer " + WM_TOKEN,
        },
        body: JSON.stringify(body),
      });
      if (!response.ok) {
        const text = await response.text();
        throw new Error(`${response.status} ${text}`);
      }
      return await response.json();
    }
    

    Submitted by hugo697 370 days ago

  • nativets
    /**
     * run flow by path and wait until completion in openai format
     *
     */
    export async function main(
      workspace: string,
      path: string,
      include_header: string | undefined,
      queue_limit: string | undefined,
      job_id: string | undefined,
      body: { [k: string]: unknown }
    ) {
      const url = new URL(
        `${BASE_URL}/api/w/${workspace}/jobs/openai_sync/f/${path}`
      );
      for (const [k, v] of [
        ["include_header", include_header],
        ["queue_limit", queue_limit],
        ["job_id", job_id],
      ]) {
        if (v !== undefined && v !== "") {
          url.searchParams.append(k, v);
        }
      }
      const response = await fetch(url, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          Authorization: "Bearer " + WM_TOKEN,
        },
        body: JSON.stringify(body),
      });
      if (!response.ok) {
        const text = await response.text();
        throw new Error(`${response.status} ${text}`);
      }
      return await response.json();
    }
    

    Submitted by hugo697 931 days ago

  • nativets
    /**
     * run flow by path and wait until completion in openai format
     *
     */
    export async function main(
      workspace: string,
      path: string,
      include_header: string | undefined,
      queue_limit: string | undefined,
      job_id: string | undefined,
      body: { [k: string]: unknown }
    ) {
      const url = new URL(
        `${BASE_URL}/api/w/${workspace}/jobs/openai_sync/f/${path}`
      );
      for (const [k, v] of [
        ["include_header", include_header],
        ["queue_limit", queue_limit],
        ["job_id", job_id],
      ]) {
        if (v !== undefined) {
          url.searchParams.append(k, v);
        }
      }
      const response = await fetch(url, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          Authorization: "Bearer " + WM_TOKEN,
        },
        body: JSON.stringify(body),
      });
      return await response.json();
    }
    

    Submitted by rubenfiszel 933 days ago

  • nativets
    /**
     * run flow by path and wait until completion in openai format
     *
     */
    export async function main(
      workspace: string,
      path: string,
      include_header: string | undefined,
      queue_limit: string | undefined,
      job_id: string | undefined,
      body: { [k: string]: unknown },
    ) {
      const url = new URL(
        `${BASE_URL}/api/w/${workspace}/jobs/openai_sync/f/${path}`,
      );
      for (const [k, v] of [
        ["include_header", include_header],
        ["queue_limit", queue_limit],
        ["job_id", job_id],
      ]) {
        if (v !== undefined) {
          url.searchParams.append(k, v);
        }
      }
      const response = await fetch(url, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          Authorization: "Bearer " + WM_TOKEN,
        },
        body: JSON.stringify(body),
      });
      return await response.json();
    }
    

    Submitted by admin 1003 days ago