Workflows

// Call submit_workflow with your BWDL definition
const result = await callTool("submit_workflow", {
  definition: {
    workflow_id: "my-first-workflow-001",
    steps: [
      {
        id: "transcode",
        tool: "transcode_from_url",
        inputs: {
          source_url: "https://example.com/video.mp4",
          output_format: "mp4"
        }
      }
    ]
  }
});

// Returns immediately
// { workflow_id: "my-first-workflow-001", status: "PROCESSING", step_count: 1 }

let status;
do {
  await sleep(5000);
  status = await callTool("get_workflow_status", {
    workflow_id: "my-first-workflow-001"
  });
} while (!["COMPLETED", "FAILED", "PARTIALLY_FAILED", "CANCELLED"].includes(status.status));

// Terminal — inspect step outputs
const step = status.steps.find(s => s.step_id === "transcode");
console.log(step.status);      // "COMPLETED"
console.log(step.output_url);  // pre-signed download URL
console.log(step.cost_usd);    // e.g. 0.001

{
  "id": "prores_master",
  "tool": "transcode_from_url",
  "depends_on": ["ingest"],
  "when": "$.params.include_prores == 'true'",
  "inputs": {
    "source_url": "$.steps.ingest.output_key",
    "output_format": "mov_prores"
  }
}

{
  "id": "upload_to_cdn",
  "tool": "transcode_from_url",
  "failure_mode": "COMPENSATE",
  "on_failure_compensate": "cleanup",
  "inputs": { "source_url": "$.params.source_url", "output_format": "mp4" }
},
{
  "id": "cleanup",
  "tool": "convert_content",
  "inputs": {
    "content": "Cleanup triggered for $.params.job_ref",
    "input_format": "txt",
    "output_format": "txt"
  }
}

"retry": {
  "max_attempts": 3,            // 1–10. Counts the original attempt — so 3 = 2 retries.
  "initial_interval_seconds": 5,// Wait before first retry. Default: 1.
  "backoff_coefficient": 2.0,   // Multiply interval on each retry. Default: 1 (no backoff).
  "retryable_errors": [         // Optional — only retry these error substrings.
    "FETCH_FAILED",
    "TIMEOUT"
  ]
}

{
  "$schema": "https://botverse.cloud/schemas/workflow/v1.json",
  "workflow_id": "multi-rendition-20240610-001",
  "version": "1.0",
  "description": "Transcode one source URL into MP4, WebM, and MP3",
  "params": {
    "source_url": "https://example.com/video.mp4"
  },
  "steps": [
    {
      "id": "ingest",
      "tool": "transcode_from_url",
      "description": "Fetch and store the source file as baseline MP4",
      "inputs": {
        "source_url": "$.params.source_url",
        "output_format": "mp4"
      }
    },
    {
      "id": "mp4",
      "tool": "transcode_from_url",
      "description": "H.264 MP4 for web delivery",
      "depends_on": ["ingest"],
      "inputs": {
        "source_url": "$.steps.ingest.output_key",
        "output_format": "mp4"
      },
      "retry": { "max_attempts": 2 }
    },
    {
      "id": "webm",
      "tool": "transcode_from_url",
      "description": "VP9 WebM for modern browsers",
      "depends_on": ["ingest"],
      "failure_mode": "SKIP_DEPENDENTS",
      "inputs": {
        "source_url": "$.steps.ingest.output_key",
        "output_format": "webm"
      }
    },
    {
      "id": "audio",
      "tool": "transcode_from_url",
      "description": "MP3 audio track",
      "depends_on": ["ingest"],
      "failure_mode": "CONTINUE",
      "inputs": {
        "source_url": "$.steps.ingest.output_key",
        "output_format": "mp3"
      }
    }
  ]
}

// Submit
const { workflow_id } = await callTool("submit_workflow", { definition });

// Poll
let result;
do {
  await new Promise(r => setTimeout(r, 5000));
  result = await callTool("get_workflow_status", { workflow_id });
} while (!["COMPLETED","FAILED","PARTIALLY_FAILED","CANCELLED"].includes(result.status));

// Collect outputs
for (const step of result.steps) {
  console.log(step.step_id, step.status, step.output_url);
}
// mp4   COMPLETED  https://storage.botverse.cloud/...?X-Amz-...
// webm  COMPLETED  https://storage.botverse.cloud/...?X-Amz-...
// audio COMPLETED  https://storage.botverse.cloud/...?X-Amz-...

{
  "workflow_id": "transcript-pack-20260622-001",
  "description": "Recording -> named Word transcript + PDF + MP3 audio",
  "params": { "recording_url": "https://storage.example.com/all-hands.mp4" },
  "steps": [
    {
      "id": "transcribe",
      "tool": "transcribe_from_url",
      "description": "Speaker-named Word transcript",
      "inputs": {
        "source_url": "$.params.recording_url",
        "output_format": "docx",
        "options": {
          "attendees": [
            { "name": "Sarah Chen", "role": "host" },
            { "name": "Mike Torres" },
            { "name": "Priya Patel" }
          ]
        }
      }
    },
    {
      "id": "audio",
      "tool": "transcode_from_url",
      "description": "MP3 of the meeting audio (runs in parallel)",
      "failure_mode": "CONTINUE",
      "inputs": {
        "source_url": "$.params.recording_url",
        "output_format": "mp3"
      }
    },
    {
      "id": "pdf",
      "tool": "convert_from_url",
      "description": "PDF rendered from the Word transcript",
      "depends_on": ["transcribe"],
      "inputs": {
        "source_url": "$.steps.transcribe.output_key",
        "output_format": "pdf"
      }
    }
  ]
}

// 1. Transcribe to JSON (one tool call, or a one-step workflow)
const { job_id } = await callTool("transcribe_from_url", {
  source_url: recordingUrl,
  output_format: "json",
  options: { attendees }
});
const transcript = await pollAndFetchJson(job_id);   // [{ start, end, speaker, text }, ...]

// 2. The agent decides where to cut — this is the part a static graph cannot do
const KEYWORD = "budget";
const CLIP = 30;                                       // seconds
const hits = transcript
  .filter(seg => seg.text.toLowerCase().includes(KEYWORD))
  .map(seg => ({ start: Math.max(0, Math.floor(seg.start) - 2) }));

const definition = {
  workflow_id: "highlights-" + Date.now(),
  description: "30s MP3 clips at every '" + KEYWORD + "' mention, plus the transcript",
  params: { recording_url: recordingUrl },
  steps: [
    // one clip per keyword hit — all parallel, soft-fail so one bad cut never sinks the batch
    ...hits.map((h, i) => ({
      id: "clip_" + i,
      tool: "transcode_from_url",
      description: "30s audio clip at " + h.start + "s",
      failure_mode: "CONTINUE",
      inputs: {
        source_url: "$.params.recording_url",
        output_format: "mp3",
        options: { start_time: String(h.start), duration: 30 }
      }
    })),
    // the transcript document, alongside the clips
    {
      id: "transcript",
      tool: "transcribe_from_url",
      inputs: {
        source_url: "$.params.recording_url",
        output_format: "docx",
        options: { attendees }
      }
    }
  ]
};

const { workflow_id } = await callTool("submit_workflow", { definition });

// 3. Poll to terminal, then save every artifact to the folder
let result;
do {
  await new Promise(r => setTimeout(r, 8000));
  result = await callTool("get_workflow_status", { workflow_id });
} while (!["COMPLETED","FAILED","PARTIALLY_FAILED","CANCELLED"].includes(result.status));

for (const step of result.steps) {
  if (step.output_url) await download(step.output_url, "./highlights/");
}