Edits history of script submission #11437 for ' Workspace or Schedule error handler (teams)'

• bun

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import dayjs from "dayjs";
  import * as wmill from "windmill-client";
  
  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`;
    }
  }
  
  function getTriggerInfo(baseUrl: string, workspace_id: string, trigger_path?: string) {
    if (trigger_path) {
      const triggerType = trigger_path.split("/")[0];
      const prettyTriggerType = triggerType.charAt(0).toUpperCase() + triggerType.replace("_", " ").slice(1);
      const triggerTypePath = triggerType === "http_trigger" ? "routes" : triggerType + "s";
      const triggerPath = trigger_path.replace(`${triggerType}/`, "");
      const url = `${baseUrl}/${triggerTypePath}?workspace=${encodeURIComponent(workspace_id)}\#${encodeURIComponent(
        triggerPath
      )}`;
      return {
        prettyTriggerType,
        triggerPath,
        url,
      };
    }
  }
  
  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
    error: object, // The error details
    started_at: string, // The start datetime of the latest job that failed
    channel: string,
    schedule_path?: string, // The path of the schedule
    trigger_path?: string, // The path of the trigger that errored in the format <trigger_type>/<trigger_path>
    failed_times?: number // Minimum number of times the schedule failed before calling the error handler
  ) {
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
    const triggerInfo = getTriggerInfo(baseUrl, workspace_id, trigger_path);
  
    let mdText = "";
    if (schedule_path) {
      mdText = `*Schedule [${schedule_path}](${scheduleUrl}) failed*${
        failed_times > 1 ? " " + failed_times + " times in a row" : ""
      }:\n- Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`;
    } else if (triggerInfo) {
      mdText = `*${triggerInfo.prettyTriggerType} [${triggerInfo.triggerPath}](${
        triggerInfo.url
      }) failed*\n- Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`;
    } else {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${
        is_flow ? "flow" : "script"
      } [${path}](${scriptOrFlowRunUrl}) failed*:`;
    }
  
    const lastFailureText = `${(failed_times ?? 1) > 1 ? "Last failed" : "Failed"} job started at: ${dayjs(
      started_at
    ).format("DD.MM.YYYY HH:mm (Z)")}\n`;
  
    await wmill.TeamsService.sendMessageToConversation({
      requestBody: {
        conversation_id: channel,
        success: true,
        text: mdText,
        card_block: {
          type: "message",
          attachments: [
            {
              contentType: "application/vnd.microsoft.card.adaptive",
              content: {
                type: "AdaptiveCard",
                body: [
                  {
                    type: "TextBlock",
                    size: "Medium",
                    weight: "Bolder",
                    text: "Error Handler",
                  },
                  {
                    type: "ColumnSet",
                    columns: [
                      {
                        type: "Column",
                        items: [
                          {
                            type: "Icon",
                            name: "Warning",
                            size: "Medium",
                            style: "Filled",
                            color: "Attention",
                          },
                        ],
                        width: "auto",
                      },
                      {
                        type: "Column",
                        items: [
                          {
                            type: "TextBlock",
                            text: mdText,
                            wrap: true,
                          },
                          {
                            type: "TextBlock",
                            text: lastFailureText,
                            wrap: true,
                          },
                          {
                            type: "CodeBlock",
                            codeSnippet: formatError(error),
                            language: "JavaScript",
                          },
                        ],
                        width: "stretch",
                      },
                    ],
                  },
                ],
                $schema: "http://adaptivecards.io/schemas/adaptive-card.json",
                version: "1.6",
              },
            },
          ],
        },
      },
    });
  }
  

  Submitted by hugo697 21 days ago

• bun

  Edit in Windmill

  Embed

  import dayjs from 'dayjs'
  import * as wmill from "windmill-client"
  
  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
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
  
    let mdText = ""
    if (schedule_path === undefined) {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"} [${path}](${scriptOrFlowRunUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
    } else {
      mdText = `*Schedule [${schedule_path}](${scheduleUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`
    }
  
    const lastFailureText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")}\n`
  
    await wmill.TeamsService.sendMessageToConversation(
      {
        requestBody: {
          conversation_id: channel,
          success: true,
          text: mdText,
          card_block: {
            "type": "message",
            "attachments": [
              {
                "contentType": "application/vnd.microsoft.card.adaptive",
                "content": {
                  "type": "AdaptiveCard",
                  "body": [
                    {
                      "type": "TextBlock",
                      "size": "Medium",
                      "weight": "Bolder",
                      "text": "Error Handler"
                    },
                    {
                      "type": "ColumnSet",
                      "columns": [
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "Icon",
                              "name": "Warning",
                              "size": "Medium",
                              "style": "Filled",
                              "color": "Attention"
                            }
                          ],
                          "width": "auto"
                        },
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "TextBlock",
                              "text": mdText,
                              "wrap": true
                            },
                            {
                              "type": "TextBlock",
                              "text": lastFailureText,
                              "wrap": true
                            },
                            {
                              "type": "CodeBlock",
                              "codeSnippet": formatError(error),
                              "language": "JavaScript"
                            }
                          ],
                          "width": "stretch"
                        }
                      ]
                    }
                  ],
                  "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
                  "version": "1.6"
                },
              }
            ]
          }
        }
      }
    )
  }

  Submitted by hugo697 86 days ago

• bun

  Edit in Windmill

  Embed

  import dayjs from 'dayjs'
  import * as wmill from "windmill-client"
  
  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
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
  
    let mdText = ""
    if (schedule_path === undefined) {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"} [${path}](${scriptOrFlowRunUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
    } else {
      mdText = `*Schedule [${schedule_path}](${scheduleUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`
    }
  
    const lastFailureText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")}\n`
  
    await wmill.TeamsService.sendMessageToConversation(
      {
        requestBody: {
          conversation_id: channel,
          success: true,
          text: mdText,
          card_block: {
            "type": "message",
            "attachments": [
              {
                "contentType": "application/vnd.microsoft.card.adaptive",
                "content": {
                  "type": "AdaptiveCard",
                  "body": [
                    {
                      "type": "TextBlock",
                      "size": "Medium",
                      "weight": "Bolder",
                      "text": "Error Handler"
                    },
                    {
                      "type": "ColumnSet",
                      "columns": [
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "Icon",
                              "name": "Warning",
                              "size": "Medium",
                              "style": "Filled",
                              "color": "Attention"
                            }
                          ],
                          "width": "auto"
                        },
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "TextBlock",
                              "text": mdText,
                              "wrap": true
                            },
                            {
                              "type": "TextBlock",
                              "text": lastFailureText,
                              "wrap": true
                            },
                            {
                              "type": "CodeBlock",
                              "codeSnippet": formatError(error),
                              "language": "JavaScript"
                            }
                          ],
                          "width": "stretch"
                        }
                      ]
                    }
                  ],
                  "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
                  "version": "1.6"
                },
              }
            ]
          }
        }
      }
    )
  }

  Submitted by alex308 175 days ago

• bun

  Edit in Windmill

  Embed

  import dayjs from 'dayjs'
  import * as wmill from "windmill-client"
  
  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
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
  
    let mdText = ""
    if (schedule_path === undefined) {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"} [${path}](${scriptOrFlowRunUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
    } else {
      mdText = `*Schedule [${schedule_path}](${scheduleUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`
    }
  
    const lastFailureText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")}\n`
  
    await wmill.TeamsService.sendMessageToConversation(
      {
        requestBody: {
          conversation_id: channel,
          success: true,
          text: mdText,
          card_block: {
            "type": "message",
            "attachments": [
              {
                "contentType": "application/vnd.microsoft.card.adaptive",
                "content": {
                  "type": "AdaptiveCard",
                  "body": [
                    {
                      "type": "TextBlock",
                      "size": "Medium",
                      "weight": "Bolder",
                      "text": "Error Handler"
                    },
                    {
                      "type": "ColumnSet",
                      "columns": [
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "Icon",
                              "name": "Warning",
                              "size": "Medium",
                              "style": "Filled",
                              "color": "Attention"
                            }
                          ],
                          "width": "auto"
                        },
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "TextBlock",
                              "text": mdText,
                              "wrap": true
                            },
                            {
                              "type": "TextBlock",
                              "text": lastFailureText,
                              "wrap": true
                            },
                            {
                              "type": "CodeBlock",
                              "codeSnippet": formatError(error),
                              "language": "JavaScript"
                            }
                          ],
                          "width": "stretch"
                        }
                      ]
                    }
                  ],
                  "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
                  "version": "1.6"
                },
              }
            ]
          }
        }
      }
    )
  }

  Submitted by alex308 175 days ago

• bun

  Edit in Windmill

  Embed

  import dayjs from 'dayjs'
  import * as wmill from "windmill-client"
  
  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
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
  
    let mdText = ""
    if (schedule_path === undefined) {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"} [${path}](${scriptOrFlowRunUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:`
    } else {
      mdText = `*Schedule [${schedule_path}](${scheduleUrl}) failed*${failed_times > 1 ? (" " + failed_times + " times in a row") : ""}:\n- Run <${jobRunUrl}|${job_id}> of ${is_flow ? "flow" : "script"}: [${path}](${scriptOrFlowRunUrl})`
    }
  
    const lastFailureText = `Last failure at: ${dayjs(started_at).format("DD.MM.YYYY HH:mm (Z)")}\n`
  
    await wmill.TeamsService.sendMessageToConversation(
      {
        requestBody: {
          conversation_id: channel,
          success: true,
          text: mdText,
          card_block: {
            "type": "message",
            "attachments": [
              {
                "contentType": "application/vnd.microsoft.card.adaptive",
                "content": {
                  "type": "AdaptiveCard",
                  "body": [
                    {
                      "type": "TextBlock",
                      "size": "Medium",
                      "weight": "Bolder",
                      "text": "Error Handler"
                    },
                    {
                      "type": "ColumnSet",
                      "columns": [
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "Icon",
                              "name": "Warning",
                              "size": "Medium",
                              "style": "Filled",
                              "color": "Attention"
                            }
                          ],
                          "width": "auto"
                        },
                        {
                          "type": "Column",
                          "items": [
                            {
                              "type": "TextBlock",
                              "text": mdText,
                              "wrap": true
                            },
                            {
                              "type": "TextBlock",
                              "text": lastFailureText,
                              "wrap": true
                            },
                            {
                              "type": "CodeBlock",
                              "codeSnippet": formatError(error),
                              "language": "JavaScript"
                            }
                          ],
                          "width": "stretch"
                        }
                      ]
                    }
                  ],
                  "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
                  "version": "1.6"
                },
              }
            ]
          }
        }
      }
    )
  }

  Submitted by alex308 175 days ago

• bun

  Edit in Windmill

  Embed

  import dayjs from 'dayjs'
  import * as wmill from "windmill-client"
  
  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
    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 jobRunUrl = baseUrl + "/run/" + job_id + "?workspace=" + encodeURIComponent(workspace_id);
  
    let mdText = ""
    if (schedule_path === undefined) {
      mdText = `*Run [${job_id}](${jobRunUrl}) of ${is_flow ? "flow" : "script"} [${path}](${scriptOrFlowRunUrl}) 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 wmill.TeamsService.sendMessageToConversation(
      {
        requestBody: {
          conversation_id: channel,
          success: false,
          text: mdText + "\n\n" + errorText
        }
      }
    )
  }

  Submitted by alex308 175 days ago