Bug Triage

# Choose ONE provider
export MINIMAX_API_KEY="sk-..."      # default provider for these pipelines
# OR
export OPENROUTER_API_KEY="sk-..."  # OpenRouter (multi-model gateway)

agentsmarket pipeline install bug-triage

# Dry-run (no API key needed)
agentsmarket pipeline call bug-triage --local --mock

# Real run (uses one of MINIMAX_API_KEY / OPENROUTER_API_KEY)
agentsmarket pipeline call bug-triage --local

# bug-triage — parses error logs → classifies severity + category → ranked report.
#
# Demonstrates: structured_json output_format with dotted-path fields,
# multi-stage DAG with depends_on, recovery plan generation as final step.
# Useful for SRE/on-call workflows.
#
# Run locally:  agentsmarket run pipelines/bug-triage.yaml --mock
name: bug-triage
version: 1.0.0
description: Parse raw error logs → classify each (severity P0-P3 + category + suggested owner) → rank by impact → emit Markdown triage report.
author_id: 0xYourAddress
license: MIT

inputs:
  logs:
    type: string
    required: true
    description: "Raw log dump from a service (stderr, log file, journalctl, etc.)"
  service_name:
    type: string
    required: false
    default: unknown-service

outputs:
  report:
    format: text
    description: "Markdown bug triage report with prioritized fix list"

defaults:
  model: MiniMax-M3

stages:
  - id: parse_logs
    provider: minimax
    system: ${BUG_TRIAGE_TONE:-You are an SRE on-call engineer. Triage with speed and precision.}
    retry:
      attempts: 3
      backoff: exponential
      retryable_status: [429, 503]
    prompt: |
      Parse the following error logs from service `{{service_name}}`.

      Output a JSON object with shape: `{"errors": [<each error as object>]}`
      Each error object must have exactly these fields:
        - `timestamp` (ISO 8601 if present, else `unknown`)
        - `level` (ERROR / WARN / FATAL / PANIC)
        - `category` (network / disk / auth / memory / cpu / config / dependency / client / unknown)
        - `message` (one-line summary)
        - `stack_top` (first 3 frames of stack, or null)
        - `recurrence_count` (how many times this same fingerprint appeared)

      Reply with valid JSON only. No prose, no markdown fences.

      Logs:
      ```
      $input.logs
      ```
    output_format: structured_json
    fields:
      - "errors[*].timestamp"
      - "errors[*].level"
      - "errors[*].category"
      - "errors[*].message"
      - "errors[*].stack_top"
      - "errors[*].recurrence_count"

  - id: classify
    provider: minimax
    depends_on: [parse_logs]
    prompt: |
      Assign priority + suggested owner team per error.

      Output a JSON object with shape: `{"items": [<each classified error>]}`
      Each item must have exactly these fields:
        - `id` (1-based index matching parse_logs order)
        - `severity` (P0 / P1 / P2 / P3 — P0 = page-now, P1 = critical, P2 = degraded, P3 = minor)
        - `summary` (≤80 chars, action-oriented)
        - `suggested_owner` (e.g., `infra`, `api`, `auth-team`, `db-team`, `frontend`, `oncall`)
        - `fix_complexity` (trivial / small / medium / large)

      Reply with valid JSON only. No prose, no markdown fences.

      Errors: $stages.parse_logs.output
    output_format: structured_json
    fields:
      - "items[*].severity"
      - "items[*].summary"
      - "items[*].suggested_owner"
      - "items[*].fix_complexity"

  - id: rank
    provider: minimax
    depends_on: [classify]
    prompt: |
      Rank items in P0 → P1 → P2 → P3 order. Within same severity, sort by
      `recurrence_count` descending (more-frequent first).
      Preserve each item's original `id`.

      Output a JSON object with shape: `{"ranked": [<ordered list of items>]}`.
      Each entry in `ranked` should include the full item object so downstream
      stages can reference `id`, `severity`, `summary`, etc.

      Reply with valid JSON only. No prose, no markdown fences.

      Classified items: $stages.classify.output
    output_format: structured_json
    fields:
      - "ranked[*].id"
      - "ranked[*].severity"
      - "ranked[*].summary"

  - id: report
    provider: minimax
    depends_on: [rank]
    prompt: |
      Write a Markdown triage report for service `{{service_name}}`.

      Structure:
        # {{service_name}} Bug Triage — {{date}}
        ## P0 (page now)
        ## P1 (critical)
        ## P2 (degraded)
        ## P3 (minor)

      Under each section list:
        - **<summary>** — _suggested owner: <team>, complexity: <X>, est. fix time: <Y>_

      Ranked list: $stages.rank.output
    output_format: text