Script 'Workspace or Schedule error handler' for slack

Workspace or Schedule error handler Failure

Verified

Error handler script sending an error message to a Slack channel. It can be used for both a global workspace error handler and specific schedules error handlers

Created by hugo697 608 days ago Viewed 99761 times

Submitted by hugo697 Bun

Verified 294 days ago

All edits

Permalink

import { WebClient } from "@slack/web-api";
import dayjs from "dayjs";

type Slack = {
  token: string;
};

function formatError(error: any) {
  if (error.stack && error.name && error.message) {
    const formatted = `*${error.name}: ${error.message}*\`\`\`\n${error.stack}\n\`\`\``;
    if (formatted.length > 2900) {
      return `\`\`\`\n${JSON.stringify(error, null, 2).substring(0, 2900)}...\n(truncated)\n\`\`\``;
    } else {
      return formatted
    }
  } else {
    const stringified = JSON.stringify(error, null, 2);
    if (stringified.length > 2900) {
      return `\`\`\`\n${stringified.substring(0, 2900)}...\n(truncated)\n\`\`\``;
    } else {
      return `\`\`\`\n${stringified}\n\`\`\``;
    }
  }
}

export async function main(
  workspace_id: string,
  job_id: string, // The UUID of the job that errored
  path: string, // The path of the script or flow that errored
  is_flow: boolean, // Whether the runnable is a flow
  schedule_path: string, // The path of the schedule
  error: object, // The error details
  started_at: string, // The start datetime of the latest job that failed
  failed_times: number, // Minimum number of times the schedule failed before calling the error handler
  slack: Slack,
  channel: string,
) {
  const baseUrl = process.env["WM_BASE_URL"];
  const scheduleUrl = baseUrl + "/runs?schedule_path=" +
    encodeURIComponent(schedule_path) + "&workspace=" + encodeURIComponent(workspace_id);
  const scriptOrFlowRunUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +
    path + "?workspace=" + encodeURIComponent(workspace_id);
  const web = new WebClient(slack.token);
  const jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);

  let rawText = ""
  if (schedule_path === undefined) {
    rawText = `${schedule_path != undefined ? `Schedule ${schedule_path} failed ` : ""}${failed_times > 1 ? (failed_times + " times in a row") : ""}`
  } else {
    rawText = `Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}|${path}> failed ${failed_times > 1 ? (failed_times + " times in a row") : ""}`
  }

  let mdText = ""
  if (schedule_path === undefined) {
    mdText = `*Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"} <${scriptOrFlowRunUrl}|${path}> failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
  } else {
    mdText = `*Schedule <${scheduleUrl}|${schedule_path}> failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}|${path}>`
  }

  const errorText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")
    }\n${formatError(error)}`

  await web.chat.postMessage({
    channel,
    text: rawText,
    blocks: [
      {
        "type": "section",
        "text": {
          "type": "mrkdwn",
          "text": mdText,
        },
      },
    ],
    attachments: [
      {
        color: "#ff0000",
        "blocks": [{
          "type": "section",
          "text": {
            "type": "mrkdwn",
            "text": errorText,
          },
        }],
        fallback: errorText
      },
    ],
  });
}

Other submissions

Submitted by hugo697 Deno

Created 608 days ago

All edits

Permalink

import { WebClient } from "@slack/web-api";
import dayjs from "dayjs";

type Slack = {
  token: string;
};

function formatError(error: any) {
  if (error.stack && error.name && error.message) {
    return `*${error.name}: ${error.message}*\`\`\`\n${error.stack}\n\`\`\``;
  } else {
    return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
  }
}

export async function main(
  workspace_id: string,
  job_id: string, // The UUID of the job that errored
  path: string, // The path of the script or flow that errored
  is_flow: boolean, // Whether the runnable is a flow
  schedule_path: string, // The path of the schedule
  error: object, // The error details
  started_at: string, // The start datetime of the latest job that failed
  failed_times: number, // Minimum number of times the schedule failed before calling the error handler
  slack: Slack,
  channel: string,
) {
  const baseUrl = process.env["WM_BASE_URL"];
  const scheduleUrl = baseUrl + "/runs?schedule_path=" +
    encodeURIComponent(schedule_path) + "&workspace=" + encodeURIComponent(workspace_id);
  const scriptOrFlowRunUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +
    path + "?workspace=" + encodeURIComponent(workspace_id);
  const web = new WebClient(slack.token);
  const jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);

  let rawText = ""
  if (schedule_path === undefined) {
    rawText = `${schedule_path != undefined ? `Schedule ${schedule_path} failed ` : ""}${failed_times > 1 ? (failed_times + " times in a row") : ""}`
  } else {
    rawText = `Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}|${path}> failed ${failed_times > 1 ? (failed_times + " times in a row") : ""}`
  }

  let mdText = ""
  if (schedule_path === undefined) {
    mdText = `*Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"} <${scriptOrFlowRunUrl}|${path}> failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
  } else {
    mdText = `*Schedule <${scheduleUrl}|${schedule_path}> failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}|${path}>`
  }

  await web.chat.postMessage({
    channel,
    text: rawText,
    blocks: [
      {
        "type": "section",
        "text": {
          "type": "mrkdwn",
          "text": mdText,
        },
      },
    ],
    attachments: [
      {
        color: "#ff0000",
        "blocks": [{
          "type": "section",
          "text": {
            "type": "mrkdwn",
            "text": `Last failure at: ${
              dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")
            }\n${formatError(error)}`,
          },
        }],
      },
    ],
  });
}


`1`	`import { WebClient } from "@slack/web-api";`
`2`	`import dayjs from "dayjs";`
`3`
`4`	`type Slack = {`
`5`	`token: string;`
`6`	`};`
`7`
`8`	`function formatError(error: any) {`
`9`	`if (error.stack && error.name && error.message) {`
`10`	const formatted = `${error.name}: ${error.message}\`\`\`\n${error.stack}\n\`\`\``;
`11`	`if (formatted.length > 2900) {`
`12`	return `\`\`\`\n${JSON.stringify(error, null, 2).substring(0, 2900)}...\n(truncated)\n\`\`\``;
`13`	`} else {`
`14`	`return formatted`
`15`	`}`
`16`	`} else {`
`17`	`const stringified = JSON.stringify(error, null, 2);`
`18`	`if (stringified.length > 2900) {`
`19`	return `\`\`\`\n${stringified.substring(0, 2900)}...\n(truncated)\n\`\`\``;
`20`	`} else {`
`21`	return `\`\`\`\n${stringified}\n\`\`\``;
`22`	`}`
`23`	`}`
`24`	`}`
`25`
`26`	`export async function main(`
`27`	`workspace_id: string,`
`28`	`job_id: string, // The UUID of the job that errored`
`29`	`path: string, // The path of the script or flow that errored`
`30`	`is_flow: boolean, // Whether the runnable is a flow`
`31`	`schedule_path: string, // The path of the schedule`
`32`	`error: object, // The error details`
`33`	`started_at: string, // The start datetime of the latest job that failed`
`34`	`failed_times: number, // Minimum number of times the schedule failed before calling the error handler`
`35`	`slack: Slack,`
`36`	`channel: string,`
`37`	`) {`
`38`	`const baseUrl = process.env["WM_BASE_URL"];`
`39`	`const scheduleUrl = baseUrl + "/runs?schedule_path=" +`
`40`	`encodeURIComponent(schedule_path) + "&workspace=" + encodeURIComponent(workspace_id);`
`41`	`const scriptOrFlowRunUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +`
`42`	`path + "?workspace=" + encodeURIComponent(workspace_id);`
`43`	`const web = new WebClient(slack.token);`
`44`	`const jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);`
`45`
`46`	`let rawText = ""`
`47`	`if (schedule_path === undefined) {`
`48`	rawText = `${schedule_path != undefined ? `Schedule ${schedule_path} failed ` : ""}${failed_times > 1 ? (failed_times + " times in a row") : ""}`
`49`	`} else {`
`50`	rawText = `Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}\|${path}> failed ${failed_times > 1 ? (failed_times + " times in a row") : ""}`
`51`	`}`
`52`
`53`	`let mdText = ""`
`54`	`if (schedule_path === undefined) {`
`55`	mdText = `Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"} <${scriptOrFlowRunUrl}\|${path}> failed${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
`56`	`} else {`
`57`	mdText = `Schedule <${scheduleUrl}\|${schedule_path}> failed${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}\|${path}>`
`58`	`}`
`59`
`60`	const errorText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")
`61`	}\n${formatError(error)}`
`62`
`63`	`await web.chat.postMessage({`
`64`	`channel,`
`65`	`text: rawText,`
`66`	`blocks: [`
`67`	`{`
`68`	`"type": "section",`
`69`	`"text": {`
`70`	`"type": "mrkdwn",`
`71`	`"text": mdText,`
`72`	`},`
`73`	`},`
`74`	`],`
`75`	`attachments: [`
`76`	`{`
`77`	`color: "#ff0000",`
`78`	`"blocks": [{`
`79`	`"type": "section",`
`80`	`"text": {`
`81`	`"type": "mrkdwn",`
`82`	`"text": errorText,`
`83`	`},`
`84`	`}],`
`85`	`fallback: errorText`
`86`	`},`
`87`	`],`
`88`	`});`
`89`	`}`

`1`	`import { WebClient } from "@slack/web-api";`
`2`	`import dayjs from "dayjs";`
`3`
`4`	`type Slack = {`
`5`	`token: string;`
`6`	`};`
`7`
`8`	`function formatError(error: any) {`
`9`	`if (error.stack && error.name && error.message) {`
`10`	return `${error.name}: ${error.message}\`\`\`\n${error.stack}\n\`\`\``;
`11`	`} else {`
`12`	return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
`13`	`}`
`14`	`}`
`15`
`16`	`export async function main(`
`17`	`workspace_id: string,`
`18`	`job_id: string, // The UUID of the job that errored`
`19`	`path: string, // The path of the script or flow that errored`
`20`	`is_flow: boolean, // Whether the runnable is a flow`
`21`	`schedule_path: string, // The path of the schedule`
`22`	`error: object, // The error details`
`23`	`started_at: string, // The start datetime of the latest job that failed`
`24`	`failed_times: number, // Minimum number of times the schedule failed before calling the error handler`
`25`	`slack: Slack,`
`26`	`channel: string,`
`27`	`) {`
`28`	`const baseUrl = process.env["WM_BASE_URL"];`
`29`	`const scheduleUrl = baseUrl + "/runs?schedule_path=" +`
`30`	`encodeURIComponent(schedule_path) + "&workspace=" + encodeURIComponent(workspace_id);`
`31`	`const scriptOrFlowRunUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +`
`32`	`path + "?workspace=" + encodeURIComponent(workspace_id);`
`33`	`const web = new WebClient(slack.token);`
`34`	`const jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);`
`35`
`36`	`let rawText = ""`
`37`	`if (schedule_path === undefined) {`
`38`	rawText = `${schedule_path != undefined ? `Schedule ${schedule_path} failed ` : ""}${failed_times > 1 ? (failed_times + " times in a row") : ""}`
`39`	`} else {`
`40`	rawText = `Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}\|${path}> failed ${failed_times > 1 ? (failed_times + " times in a row") : ""}`
`41`	`}`
`42`
`43`	`let mdText = ""`
`44`	`if (schedule_path === undefined) {`
`45`	mdText = `Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"} <${scriptOrFlowRunUrl}\|${path}> failed${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
`46`	`} else {`
`47`	mdText = `Schedule <${scheduleUrl}\|${schedule_path}> failed${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run <${jobRunUrl}\|${job_id}> of ${is_flow ? "flow" : "script"}: <${scriptOrFlowRunUrl}\|${path}>`
`48`	`}`
`49`
`50`	`await web.chat.postMessage({`
`51`	`channel,`
`52`	`text: rawText,`
`53`	`blocks: [`
`54`	`{`
`55`	`"type": "section",`
`56`	`"text": {`
`57`	`"type": "mrkdwn",`
`58`	`"text": mdText,`
`59`	`},`
`60`	`},`
`61`	`],`
`62`	`attachments: [`
`63`	`{`
`64`	`color: "#ff0000",`
`65`	`"blocks": [{`
`66`	`"type": "section",`
`67`	`"text": {`
`68`	`"type": "mrkdwn",`
`69`	"text": `Last failure at: ${
`70`	`dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")`
`71`	}\n${formatError(error)}`,
`72`	`},`
`73`	`}],`
`74`	`},`
`75`	`],`
`76`	`});`
`77`	`}`
`78`