logo Windmill Hub
Login
← Back to the list of replies

Edits history of script submission #825 for ' run flow preview (windmill)'

  • nativets
    One script reply has been approved by the moderators
    Ap­pro­ved 
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "mssql"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        delete_after_use?: boolean;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          self_approval_disabled?: boolean;
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            random_factor?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "mssql"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        delete_after_use?: boolean;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          self_approval_disabled?: boolean;
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            random_factor?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      priority?: number;
      early_return?: string;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    restarted_from?: {
      flow_job_id?: string;
      step_id?: string;
      branch_or_iteration_n?: number;
      [k: string]: unknown;
    };
    [k: string]: unknown;
  }
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by hugo697 370 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "mssql"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        delete_after_use?: boolean;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          self_approval_disabled?: boolean;
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            random_factor?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "mssql"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        delete_after_use?: boolean;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          self_approval_disabled?: boolean;
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            random_factor?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      priority?: number;
      early_return?: string;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    restarted_from?: {
      flow_job_id?: string;
      step_id?: string;
      branch_or_iteration_n?: number;
      [k: string]: unknown;
    };
    [k: string]: unknown;
  }
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by hugo697 797 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      priority?: number;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    restarted_from?: {
      flow_job_id?: string;
      step_id?: string;
      [k: string]: unknown;
    };
    [k: string]: unknown;
  }
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by hugo697 925 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        priority?: number;
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      priority?: number;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    [k: string]: unknown;
  }
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by hugo697 931 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    [k: string]: unknown;
  }
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by rubenfiszel 933 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              parallelism?: number;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          user_auth_required?: boolean;
          user_groups_required?:
            | { value?: unknown; type: "javascript"; [k: string]: unknown }
            | { expr: string; type: "javascript"; [k: string]: unknown };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      concurrent_limit?: number;
      concurrency_time_window_s?: number;
      skip_expr?: string;
      cache_ttl?: number;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    [k: string]: unknown;
  },
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by admin 933 days ago

  • nativets
    /**
 * run flow preview
 *
 */
export async function main(
  workspace: string,
  include_header: string | undefined,
  invisible_to_owner: string | undefined,
  job_id: string | undefined,
  body: {
    value: {
      modules: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      }[];
      failure_module?: {
        id: string;
        value:
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              content: string;
              language:
                | "deno"
                | "bun"
                | "python3"
                | "go"
                | "bash"
                | "powershell"
                | "postgresql"
                | "mysql"
                | "bigquery"
                | "snowflake"
                | "graphql"
                | "nativets";
              path?: string;
              lock?: string;
              type: "rawscript";
              tag?: string;
              concurrent_limit?: number;
              concurrency_time_window_s?: number;
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              hash?: string;
              type: "script";
              [k: string]: unknown;
            }
          | {
              input_transforms: {
                [k: string]:
                  | {
                      value?: unknown;
                      type: "javascript";
                      [k: string]: unknown;
                    }
                  | { expr: string; type: "javascript"; [k: string]: unknown };
              };
              path: string;
              type: "flow";
              [k: string]: unknown;
            }
          | {
              modules: { [k: string]: unknown }[];
              iterator:
                | { value?: unknown; type: "javascript"; [k: string]: unknown }
                | { expr: string; type: "javascript"; [k: string]: unknown };
              skip_failures: boolean;
              type: "forloopflow";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                expr: string;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              default: { [k: string]: unknown }[];
              type: "branchone";
              [k: string]: unknown;
            }
          | {
              branches: {
                summary?: string;
                skip_failure?: boolean;
                modules: { [k: string]: unknown }[];
                [k: string]: unknown;
              }[];
              type: "branchall";
              parallel?: boolean;
              [k: string]: unknown;
            }
          | { type: "identity"; flow?: boolean; [k: string]: unknown }
          | { type: "graphql"; [k: string]: unknown };
        stop_after_if?: {
          skip_if_stopped?: boolean;
          expr: string;
          [k: string]: unknown;
        };
        sleep?:
          | { value?: unknown; type: "javascript"; [k: string]: unknown }
          | { expr: string; type: "javascript"; [k: string]: unknown };
        cache_ttl?: number;
        timeout?: number;
        summary?: string;
        mock?: {
          enabled?: boolean;
          return_value?: unknown;
          [k: string]: unknown;
        };
        suspend?: {
          required_events?: number;
          timeout?: number;
          resume_form?: {
            schema?: { [k: string]: unknown };
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        retry?: {
          constant?: {
            attempts?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          exponential?: {
            attempts?: number;
            multiplier?: number;
            seconds?: number;
            [k: string]: unknown;
          };
          [k: string]: unknown;
        };
        [k: string]: unknown;
      };
      same_worker?: boolean;
      [k: string]: unknown;
    };
    path?: string;
    args: { [k: string]: unknown };
    tag?: string;
    [k: string]: unknown;
  },
) {
  const url = new URL(`${BASE_URL}/api/w/${workspace}/jobs/run/preview_flow`);
  for (const [k, v] of [
    ["include_header", include_header],
    ["invisible_to_owner", invisible_to_owner],
    ["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.text();
}

    Submitted by admin 1003 days ago

← Back to the list of replies