the workflow library

etl-quarantine

{"t2-invoice-chaser":"nika: v1\nworkflow:\n  id: invoice-chaser\n  description: \"Ledger CSV → overdue filter → drafted reminders → human gate → drafts file\"\n\nmodel: ollama/qwen3.5:4b   # local · zero key · swap for groq/llama-3.3-70b (drafting is a fast-model job)\n\nvars:\n  ledger_csv: \"./finance/invoices.csv\"\n\ntasks:\n  ledger:\n    invoke:\n      tool: \"nika:read\"\n      args: { path: \"${{ vars.ledger_csv }}\" }\n\n  rows:\n    with:\n      csv: ${{ tasks.ledger.output }}\n    invoke:\n      tool: \"nika:convert\"\n      args:\n        input: \"${{ with.csv }}\"\n        from: csv\n        to: json\n        has_header: true\n\n  overdue:\n    with:\n      rows: ${{ tasks.rows.output }}\n    invoke:\n      tool: \"nika:jq\"\n      args:\n        input: \"${{ with.rows }}\"\n        expression: 'map(select(.status == \"overdue\"))'\n\n  drafts:\n    with:\n      overdue: ${{ tasks.overdue.output }}\n    when: ${{ size(with.overdue) > 0 }}\n    infer:\n      prompt: |\n        Draft one short, polite payment reminder per overdue invoice ·\n        ${{ with.overdue }}\n        Markdown · one section per client · firm but warm.\n\n  approve:\n    with:\n      drafts: ${{ tasks.drafts.output }}\n    when: ${{ with.drafts != null }}   # nothing drafted · nothing to approve\n    invoke:\n      tool: \"nika:prompt\"\n      args:\n        message: \"Save the reminder drafts for sending?\"\n        default: false\n\n  save:\n    with:\n      drafts: ${{ tasks.drafts.output }}\n      approved: ${{ tasks.approve.output }}\n    when: ${{ with.drafts != null && with.approved == true }}   # zero overdue → drafts skipped (null) · don't write nothing\n    invoke:\n      tool: \"nika:write\"\n      args:\n        path: \"./finance/reminders-to-send.md\"\n        content: \"${{ with.drafts }}\"\n\noutputs:\n  overdue:\n    value: ${{ tasks.overdue.output }}\n    description: \"The overdue rows the reminders were drafted for\"\n","t4-deep-research-brief":"nika: v1\nworkflow:\n  id: deep-research-brief\n  description: \"plan → budgeted research agent → thinking synthesis → brief on disk\"\n\nmodel: ollama/qwen3.5:4b   # local default · per-task overrides below pick stronger models\n\nvars:\n  topic:\n    type: string\n    required: true\n    description: \"What to research\"\n\ntasks:\n  plan:\n    infer:\n      model: anthropic/claude-haiku-4-5    # planning is a fast-model job\n      prompt: \"Break '${{ vars.topic }}' into 4 sharp research queries · no overlap.\"\n      schema:\n        type: object\n        required: [queries]\n        properties:\n          queries:\n            type: array\n            items: { type: string }\n\n  investigate:\n    with:\n      plan_queries: ${{ tasks.plan.output.queries }}\n    agent:\n      system: |\n        You are a rigorous researcher. Work the queries one by one ·\n        fetch sources · keep verbatim quotes · note what each source\n        actually supports. Call nika:done when the plan is exhausted.\n      prompt: \"Research plan · ${{ with.plan_queries }}\"\n      tools:\n        - \"nika:fetch\"                 # the web\n        - \"nika:write\"                 # scratch notes\n        - \"nika:done\"                  # the loop-completion sentinel\n      max_turns: 25\n      max_tokens_total: 150000\n      schema:\n        type: object\n        required: [findings, sources]\n        properties:\n          findings:\n            type: array\n            items: { type: string }\n          sources:\n            type: array\n            items: { type: string }\n\n  brief:\n    with:\n      investigate_findings: ${{ tasks.investigate.output.findings }}\n      investigate_sources: ${{ tasks.investigate.output.sources }}\n    infer:\n      prompt: |\n        Findings · ${{ with.investigate_findings }}\n        Sources · ${{ with.investigate_sources }}\n        Write the executive brief · what's true · what's contested ·\n        what it means · what to do. Two pages max.\n      thinking:\n        enabled: true\n        budget_tokens: 8000\n\n  save:\n    with:\n      brief: ${{ tasks.brief.output }}\n    invoke:\n      tool: \"nika:write\"\n      args:\n        path: \"./research/${{ vars.topic }}.md\"\n        content: \"${{ with.brief }}\"\n        create_dirs: true\n\noutputs:\n  brief: ${{ tasks.brief.output }}\n  sources:\n    value: ${{ tasks.investigate.output.sources }}\n    description: \"Every source the agent actually used\"\n","t3-localization-factory":"nika: v1\nworkflow:\n  id: localization-factory\n  description: \"glob docs → parallel read → parallel translate → mirror tree\"\n\nmodel: ollama/qwen3.5:4b   # local default · swap for mistral/mistral-large (EU model for EU locales)\n\nvars:\n  lang: \"fr\"\n  source_glob: \"./docs/**/*.md\"\n\ntasks:\n  files:\n    invoke:\n      tool: \"nika:glob\"\n      args:\n        pattern: \"${{ vars.source_glob }}\"\n        exclude: [\"**/node_modules/**\"]\n\n  texts:\n    with:\n      files: ${{ tasks.files.output }}\n    for_each: ${{ with.files }}\n    max_parallel: 8\n    invoke:\n      tool: \"nika:read\"\n      args: { path: \"${{ item }}\" }\n\n  pairs:\n    with:\n      files: ${{ tasks.files.output }}\n      texts: ${{ tasks.texts.output }}\n    invoke:\n      tool: \"nika:jq\"\n      args:\n        input: [\"${{ with.files }}\", \"${{ with.texts }}\"]\n        expression: \"transpose | map({path: .[0], text: .[1]})\"\n\n  translated:\n    with:\n      pairs: ${{ tasks.pairs.output }}\n    for_each: ${{ with.pairs }}\n    max_parallel: 3                    # rate-limit the provider\n    fail_fast: false                   # finish the batch · a failed file yields null at its index\n    on_error:\n      recover: null                    # null keeps the transpose zip aligned (order preserved)\n    infer:\n      prompt: |\n        Translate to ${{ vars.lang }} · keep markdown structure, code blocks\n        untouched, and the original tone ·\n        ${{ item.text }}\n\n  bundle:\n    with:\n      pairs: ${{ tasks.pairs.output }}\n      translated: ${{ tasks.translated.output }}\n    invoke:\n      tool: \"nika:jq\"\n      args:\n        input: [\"${{ with.pairs }}\", \"${{ with.translated }}\"]\n        expression: \"transpose | map(select(.[1] != null)) | map({path: .[0].path, text: .[1]})\"\n\n  mirror:\n    with:\n      bundle: ${{ tasks.bundle.output }}\n    for_each: ${{ with.bundle }}\n    max_parallel: 8\n    invoke:\n      tool: \"nika:write\"\n      args:\n        path: \"./i18n/${{ vars.lang }}/${{ item.path }}\"\n        content: \"${{ item.text }}\"\n        create_dirs: true\n\noutputs:\n  files:\n    value: ${{ tasks.files.output }}\n    description: \"Every source file that was mirrored\"\n"}

zero model · bad rows quarantine, good rows aggregate. This file carries a real recorded trace — the home page replays it, beat for beat, from the run record.

7tasksthe plan below walks them
5wavesrun together when they can
invokeverbthe whole grammar it speaks
recordeda real runthe trace is the proof

the plan

derived from the file, never drawn by hand

empty_batchinvokerawinvoke

rowsinvoke

checkinvoke

goodinvokequarantineinvoke

reportinvoke

the file, whole

etl-quarantine.nika.yaml

1nika: v12workflow:3  id: etl-quarantine4# zero model · a schema gate splits the batch56# the file IS the blast radius7permits:8  fs: { read: [ ./data/incoming/* ], write: [ ./data/* ] }9  tools: [ "nika:read", "nika:convert", "nika:validate", "nika:jq", "nika:write" ]1011tasks:12  # the deterministic fallback if parsing dies13  empty_batch:14    ◆invoke: { tool: "nika:jq", args: { input: [], expression: "." } }1516  raw:17    ◆invoke: { tool: "nika:read", args: { path: ./data/incoming/orders.csv } }1819  rows:20    with:21      raw: ${{ tasks.raw.output }}22    ◆invoke:23      tool: "nika:convert"24      args: { input: "${{ with.raw }}", from: csv, to: json, has_header: true }25    # malformed CSV → empty batch · the run survives26    on_error:27      recover: ${{ tasks.empty_batch.output }}2829  check:30    with:31      rows: ${{ tasks.rows.output }}32    ◆invoke:33      tool: "nika:validate"34      args:35        data: "${{ with.rows }}"36        format: json37        schema:38          type: array39          items:40            type: object41            required: [ order_id, amount, currency ]42            properties:43              order_id: { type: string }44              amount: { type: string }45              currency: { type: string, enum: [ EUR, USD, GBP ] }4647  good:48    with:49      rows: ${{ tasks.rows.output }}50      valid: ${{ tasks.check.output.valid }}51    when: ${{ with.valid == true }}52    ◆invoke:53      tool: "nika:jq"54      args:55        input: "${{ with.rows }}"56        expression: 'group_by(.currency) | map({currency: .[0].currency, orders: length, total: (map(.amount | tonumber) | add)})'5758  quarantine:59    with:60      valid: ${{ tasks.check.output.valid }}61      errors: ${{ tasks.check.output.errors }}62    when: ${{ with.valid == false }}63    ◆invoke:64      tool: "nika:write"65      args:66        path: ./data/quarantine/rejected.json67        content: "${{ with.errors }}"68        create_dirs: true6970  report:71    with:72      totals: ${{ tasks.good.output }}   # value edge · passes when good is skipped (reads null)73    when: ${{ with.totals != null && size(with.totals) > 0 }}74    ◆invoke:75      tool: "nika:write"76      args:77        path: ./data/daily-totals.json78        content: "${{ with.totals }}"79        create_dirs: true8081outputs:82  totals: "${{ tasks.good.output }}"83

lines 25–27: on_error: a bad batch degrades, the run survives. Source: the served copy · byte-pinned to the recorded trace by the honesty suite · open it in the playground →

Watch the recorded one replay on the home page, walk the showcase gallery, or install and run the file yourself.