Finishing a deferred step

import {Workflows} from "attio/server"
import block from "./block"

export default Workflows.defineWorkflowBlockFinish(block, async (req, {config, metadata}) => {
  const payload = await req.json()

  if (payload.status === "pending") {
    // Job not done yet — stay deferred and wait for the next callback
    return {type: "no-op"}
  }

  if (payload.status === "cancelled") {
    // End the run without raising an error
    return {type: "exit"}
  }

  if (payload.status === "failed") {
    // Surface the error; set retryable: true for transient failures
    return {
      type: "error",
      errorMessage: payload.message,
      retryable: payload.transient, // optional, defaults to false
    }
  }

  // Continue the workflow down the "success" branch
  return {type: "outcome", id: "success", data: null}
})