nika: v1
workflow:
  id: ceo-monday-brief
  description: "news + repo pulse + KPIs → thinking synthesis → dated brief + cost ping"

model: ollama/qwen3.5:4b   # local default · the synthesis task below overrides to a stronger model

vars:
  watch_query: "AI workflow engines"
  kpi_csv: "./finance/kpis.csv"

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

tasks:
  # ── branch 1 · market signal ──
  news:
    invoke:
      tool: "nika:fetch"
      args:
        url: "https://hn.algolia.com/api/v1/search?query=${{ vars.watch_query }}"
        mode: jq
        jq: ".hits[:10] | map(.title)"

  # ── branch 2 · engineering pulse ──
  pulse:
    exec:
      command: ["git", "shortlog", "-sn", "--since=1 week ago"]

  # ── branch 3 · the numbers ──
  kpi_raw:
    invoke:
      tool: "nika:read"
      args: { path: "${{ vars.kpi_csv }}" }

  kpis:
    with:
      csv: ${{ tasks.kpi_raw.output }}
    invoke:
      tool: "nika:convert"
      args:
        input: "${{ with.csv }}"
        from: csv
        to: json
        has_header: true

  revenue:
    with:
      kpis: ${{ tasks.kpis.output }}
    invoke:
      tool: "nika:jq"
      args:
        input: "${{ with.kpis }}"
        expression: "map(.weekly_revenue | tonumber) | add"

  # ── synthesis · with a thinking budget ──
  brief:
    with:                              # the three branches join here · four value edges
      news: ${{ tasks.news.output }}
      pulse: ${{ tasks.pulse.output }}
      kpis: ${{ tasks.kpis.output }}
      revenue: ${{ tasks.revenue.output }}
    infer:
      model: anthropic/claude-sonnet-4-6   # per-task override · thinking budget
      prompt: |
        Market signal · ${{ with.news }}
        Engineering pulse · ${{ with.pulse }}
        KPIs · ${{ with.kpis }}
        Revenue (summed) · ${{ with.revenue }}

        Write my Monday brief · 5 sections · market · product ·
        numbers · risks · the ONE decision this week needs.
      thinking:
        enabled: true
        budget_tokens: 10000

  stamp:
    invoke:
      tool: "nika:date"
      args: { op: now }
    output:
      day: ".[:10]"                  # nika:date returns the ISO string itself · slice YYYY-MM-DD

  save:
    with:
      day: ${{ tasks.stamp.day }}
      brief: ${{ tasks.brief.output }}
    invoke:
      tool: "nika:write"
      args:
        path: "./briefs/${{ with.day }}-monday.md"
        content: "${{ with.brief }}"
        create_dirs: true

  # ── the run reports its own bill ──
  bill:
    after:
      save: succeeded                # state, no data · read the meter once the brief landed
    invoke:
      tool: "nika:inspect"
      args: { view: cost }

  ping:
    with:
      day: ${{ tasks.stamp.day }}    # hoisted once · the body AND the cleanup below read this binding
      cost: ${{ tasks.bill.output.total_usd }}
    invoke:
      tool: "nika:notify"
      args:
        channel: webhook
        target: "${{ secrets.founders_webhook }}"
        message: "Monday brief ready · briefs/${{ with.day }}-monday.md · run cost ${{ with.cost }}"
        severity: info
    on_finally:
      - invoke:
          tool: "nika:emit"
          args:
            event_type: "brief.monday.run"
            payload:
              day: "${{ with.day }}"   # the parent's own binding · cleanup never reads a sibling task

outputs:
  brief: ${{ tasks.brief.output }}
  cost_usd: ${{ tasks.bill.output.total_usd }}

{"a":{"graph_format":2,"workflow":"ceo-monday-brief","nodes":[{"id":"news","verb":"invoke","tool":"nika:fetch","permits":["tool: nika:fetch"]},{"id":"pulse","verb":"exec","permits":["exec: git"]},{"id":"kpi_raw","verb":"invoke","tool":"nika:read","permits":["tool: nika:read"]},{"id":"stamp","verb":"invoke","tool":"nika:date","permits":["tool: nika:date"]},{"id":"kpis","verb":"invoke","tool":"nika:convert","permits":["tool: nika:convert"]},{"id":"revenue","verb":"invoke","tool":"nika:jq","permits":["tool: nika:jq"]},{"id":"brief","verb":"infer","model":"anthropic/claude-sonnet-4-6","permits":[]},{"id":"save","verb":"invoke","tool":"nika:write","permits":["tool: nika:write"]},{"id":"bill","verb":"invoke","tool":"nika:inspect","permits":["tool: nika:inspect"]},{"id":"ping","verb":"invoke","tool":"nika:notify","permits":["tool: nika:emit","tool: nika:notify"]}],"edges":[{"from":"bill","to":"ping","kind":"value"},{"from":"brief","to":"save","kind":"value"},{"from":"kpi_raw","to":"kpis","kind":"value"},{"from":"kpis","to":"brief","kind":"value"},{"from":"kpis","to":"revenue","kind":"value"},{"from":"news","to":"brief","kind":"value"},{"from":"pulse","to":"brief","kind":"value"},{"from":"revenue","to":"brief","kind":"value"},{"from":"save","to":"bill","kind":"control"},{"from":"stamp","to":"ping","kind":"value"},{"from":"stamp","to":"save","kind":"value"}]},"engine":"0.105.0"}

showcase · tier 4 · research

CEO Monday brief

Market + repo pulse + KPI sheet gathered in parallel, jq sums the revenue, thinking model writes.

The ping ends with the run’s own cost line. The workflow reports its own bill. · conformance-gated in nika-spec ↗ · re-proven at every push

The whole file

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

t4-ceo-monday-brief.nika.yamlsource

1nika: v12workflow:3  id: ceo-monday-brief4  description: "news + repo pulse + KPIs → thinking synthesis → dated brief + cost ping"56model: ollama/qwen3.5:4b   # local default · the synthesis task below overrides to a stronger model78vars:9  watch_query: "AI workflow engines"10  kpi_csv: "./finance/kpis.csv"1112secrets:13  founders_webhook:14    source: env15    key: FOUNDERS_WEBHOOK_URL16    egress:                       # sanction the one send · the secret IS the URL17      - to: "nika:notify"18        host_from_self: true1920tasks:21  # ── branch 1 · market signal ──22  news:23    ◆invoke:24      tool: "nika:fetch"25      args:26        url: "https://hn.algolia.com/api/v1/search?query=${{ vars.watch_query }}"27        mode: jq28        jq: ".hits[:10] | map(.title)"2930  # ── branch 2 · engineering pulse ──31  pulse:32    ▷exec:33      command: ["git", "shortlog", "-sn", "--since=1 week ago"]3435  # ── branch 3 · the numbers ──36  kpi_raw:37    ◆invoke:38      tool: "nika:read"39      args: { path: "${{ vars.kpi_csv }}" }4041  kpis:42    with:43      csv: ${{ tasks.kpi_raw.output }}44    ◆invoke:45      tool: "nika:convert"46      args:47        input: "${{ with.csv }}"48        from: csv49        to: json50        has_header: true5152  revenue:53    with:54      kpis: ${{ tasks.kpis.output }}55    ◆invoke:56      tool: "nika:jq"57      args:58        input: "${{ with.kpis }}"59        expression: "map(.weekly_revenue | tonumber) | add"6061  # ── synthesis · with a thinking budget ──62  brief:63    with:                              # the three branches join here · four value edges64      news: ${{ tasks.news.output }}65      pulse: ${{ tasks.pulse.output }}66      kpis: ${{ tasks.kpis.output }}67      revenue: ${{ tasks.revenue.output }}68    ◇infer:69      model: anthropic/claude-sonnet-4-6   # per-task override · thinking budget70      prompt: |71        Market signal · ${{ with.news }}72        Engineering pulse · ${{ with.pulse }}73        KPIs · ${{ with.kpis }}74        Revenue (summed) · ${{ with.revenue }}7576        Write my Monday brief · 5 sections · market · product ·77        numbers · risks · the ONE decision this week needs.78      thinking:79        enabled: true80        budget_tokens: 100008182  stamp:83    ◆invoke:84      tool: "nika:date"85      args: { op: now }86    output:87      day: ".[:10]"                  # nika:date returns the ISO string itself · slice YYYY-MM-DD8889  save:90    with:91      day: ${{ tasks.stamp.day }}92      brief: ${{ tasks.brief.output }}93    ◆invoke:94      tool: "nika:write"95      args:96        path: "./briefs/${{ with.day }}-monday.md"97        content: "${{ with.brief }}"98        create_dirs: true99100  # ── the run reports its own bill ──101  bill:102    after:103      save: succeeded                # state, no data · read the meter once the brief landed104    ◆invoke:105      tool: "nika:inspect"106      args: { view: cost }107108  ping:109    with:110      day: ${{ tasks.stamp.day }}    # hoisted once · the body AND the cleanup below read this binding111      cost: ${{ tasks.bill.output.total_usd }}112    ◆invoke:113      tool: "nika:notify"114      args:115        channel: webhook116        target: "${{ secrets.founders_webhook }}"117        message: "Monday brief ready · briefs/${{ with.day }}-monday.md · run cost $${{ with.cost }}"118        severity: info119    on_finally:120      - ◆invoke:121          tool: "nika:emit"122          args:123            event_type: "brief.monday.run"124            payload:125              day: "${{ with.day }}"   # the parent's own binding · cleanup never reads a sibling task126127outputs:128  brief: ${{ tasks.brief.output }}129  cost_usd: ${{ tasks.bill.output.total_usd }}130

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

11 declared edges · 7 waves · the plan falls out of the bindings

try itopen in the playground guidethe walkthrough · docs verbinvoke verbexec verbinfer toolnika:fetch toolnika:read toolnika:convert toolnika:jq toolnika:date toolnika:write toolnika:inspect toolnika:notify