nika: v1
workflow:
  id: competitor-radar
  description: "Sitemap → parallel page reads → one competitive brief + ping"

model: ollama/qwen3.5:4b   # local · zero key · swap for anthropic/claude-sonnet-4-6

vars:
  competitor_sitemap: "https://competitor.example.com/sitemap.xml"

secrets:
  team_webhook:
    source: env
    key: TEAM_WEBHOOK_URL
    egress:                       # sanction the one send · the secret IS the URL
      - to: "nika:notify"
        host_from_self: true

tasks:
  map:
    invoke:
      tool: "nika:fetch"
      args:
        url: "${{ vars.competitor_sitemap }}"
        mode: sitemap
    output:
      recent: ".[:8] | map(.loc)"     # sitemap = the root array of {loc, …} · cap at 8, keep the URLs

  pages:
    with:
      map_recent: ${{ tasks.map.recent }}
    for_each: ${{ with.map_recent }}
    max_parallel: 4                    # be polite · 4 fetches in flight max
    fail_fast: false                   # one dead page must not kill the radar
    on_error:
      recover: null                    # a dead page yields null at its index · the radar lives
    timeout: "30s"
    retry:
      max_attempts: 3
      backoff_strategy: exponential
      jitter: true
    invoke:
      tool: "nika:fetch"
      args:
        url: "${{ item }}"
        mode: article

  digest:
    with:
      pages: ${{ tasks.pages.output }}
    infer:
      prompt: |
        These are the pages a competitor published recently ·
        ${{ with.pages }}
        Write the Monday brief · what they shipped · what it signals ·
        what we should watch. One page, plain words.

  save:
    with:
      digest: ${{ tasks.digest.output }}
    invoke:
      tool: "nika:write"
      args:
        path: "./radar/competitor-brief.md"
        content: "${{ with.digest }}"
        create_dirs: true

  ping:
    after:
      save: succeeded
    invoke:
      tool: "nika:notify"
      args:
        channel: webhook
        target: "${{ secrets.team_webhook }}"
        message: "Competitor radar is ready · ./radar/competitor-brief.md"
        severity: info

outputs:
  brief: ${{ tasks.digest.output }}

{"a":{"graph_format":2,"workflow":"competitor-radar","nodes":[{"id":"map","verb":"invoke","tool":"nika:fetch","permits":["tool: nika:fetch"]},{"id":"pages","verb":"invoke","tool":"nika:fetch","fan_out":{"kind":"expression"},"permits":["tool: nika:fetch"]},{"id":"digest","verb":"infer","model":"ollama/qwen3.5:4b","permits":[]},{"id":"save","verb":"invoke","tool":"nika:write","permits":["fs.write: ./radar/competitor-brief.md","tool: nika:write"]},{"id":"ping","verb":"invoke","tool":"nika:notify","permits":["tool: nika:notify"]}],"edges":[{"from":"digest","to":"save","kind":"value"},{"from":"map","to":"pages","kind":"value"},{"from":"pages","to":"digest","kind":"value"},{"from":"save","to":"ping","kind":"control"}]},"engine":"0.105.0"}

showcase · tier 3 · research

Competitor radar

Maps their sitemap, reads the freshest pages in parallel with retry, then digests one brief.

Monday 8am, everything they shipped last week is on your desk, with what it signals. · conformance-gated in nika-spec ↗ · re-proven at every push

The whole file

5 tasks · 5 waves · the plan falls out of the bindings, nothing is scheduled by hand.

t3-competitor-radar.nika.yamlsource

1nika: v12workflow:3  id: competitor-radar4  description: "Sitemap → parallel page reads → one competitive brief + ping"56model: ollama/qwen3.5:4b   # local · zero key · swap for anthropic/claude-sonnet-4-678vars:9  competitor_sitemap: "https://competitor.example.com/sitemap.xml"1011secrets:12  team_webhook:13    source: env14    key: TEAM_WEBHOOK_URL15    egress:                       # sanction the one send · the secret IS the URL16      - to: "nika:notify"17        host_from_self: true1819tasks:20  map:21    ◆invoke:22      tool: "nika:fetch"23      args:24        url: "${{ vars.competitor_sitemap }}"25        mode: sitemap26    output:27      recent: ".[:8] | map(.loc)"     # sitemap = the root array of {loc, …} · cap at 8, keep the URLs2829  pages:30    with:31      map_recent: ${{ tasks.map.recent }}32    for_each: ${{ with.map_recent }}33    max_parallel: 4                    # be polite · 4 fetches in flight max34    fail_fast: false                   # one dead page must not kill the radar35    on_error:36      recover: null                    # a dead page yields null at its index · the radar lives37    timeout: "30s"38    retry:39      max_attempts: 340      backoff_strategy: exponential41      jitter: true42    ◆invoke:43      tool: "nika:fetch"44      args:45        url: "${{ item }}"46        mode: article4748  digest:49    with:50      pages: ${{ tasks.pages.output }}51    ◇infer:52      prompt: |53        These are the pages a competitor published recently ·54        ${{ with.pages }}55        Write the Monday brief · what they shipped · what it signals ·56        what we should watch. One page, plain words.5758  save:59    with:60      digest: ${{ tasks.digest.output }}61    ◆invoke:62      tool: "nika:write"63      args:64        path: "./radar/competitor-brief.md"65        content: "${{ with.digest }}"66        create_dirs: true6768  ping:69    after:70      save: succeeded71    ◆invoke:72      tool: "nika:notify"73      args:74        channel: webhook75        target: "${{ secrets.team_webhook }}"76        message: "Competitor radar is ready · ./radar/competitor-brief.md"77        severity: info7879outputs:80  brief: ${{ tasks.digest.output }}81

nika inspect · engine 0.105.0 · vendored graph, never re-derived

4 declared edges · 5 waves · the plan falls out of the bindings

try itopen in the playground guidethe walkthrough · docs verbinvoke verbinfer toolnika:fetch toolnika:write toolnika:notify