the workflow library

t3-localization-factory

{"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"}

every doc translated in parallel, the tree mirrored back. A pack showcase file, shown whole to read; nika run t3-localization-factory.nika.yaml is the honest affordance — this site never fabricates a replay for it.

6tasksthe plan below walks them
6wavesrun together when they can
invoke · inferverbsthe whole grammar it speaks
browseread, then runno fabricated replay

the plan

derived from the file, never drawn by hand

filesinvoke

textsinvoke

pairsinvoke

translatedinfer

bundleinvoke

mirrorinvoke

the file, whole

t3-localization-factory.nika.yaml

1nika: v12workflow:3  id: localization-factory4  description: "glob docs → parallel read → parallel translate → mirror tree"56model: ollama/qwen3.5:4b   # local default · swap for mistral/mistral-large (EU model for EU locales)78vars:9  lang: "fr"10  source_glob: "./docs/**/*.md"1112tasks:13  files:14    ◆invoke:15      tool: "nika:glob"16      args:17        pattern: "${{ vars.source_glob }}"18        exclude: ["**/node_modules/**"]1920  texts:21    with:22      files: ${{ tasks.files.output }}23    for_each: ${{ with.files }}24    max_parallel: 825    ◆invoke:26      tool: "nika:read"27      args: { path: "${{ item }}" }2829  pairs:30    with:31      files: ${{ tasks.files.output }}32      texts: ${{ tasks.texts.output }}33    ◆invoke:34      tool: "nika:jq"35      args:36        input: ["${{ with.files }}", "${{ with.texts }}"]37        expression: "transpose | map({path: .[0], text: .[1]})"3839  translated:40    with:41      pairs: ${{ tasks.pairs.output }}42    for_each: ${{ with.pairs }}43    max_parallel: 3                    # rate-limit the provider44    fail_fast: false                   # finish the batch · a failed file yields null at its index45    on_error:46      recover: null                    # null keeps the transpose zip aligned (order preserved)47    ◇infer:48      prompt: |49        Translate to ${{ vars.lang }} · keep markdown structure, code blocks50        untouched, and the original tone ·51        ${{ item.text }}5253  bundle:54    with:55      pairs: ${{ tasks.pairs.output }}56      translated: ${{ tasks.translated.output }}57    ◆invoke:58      tool: "nika:jq"59      args:60        input: ["${{ with.pairs }}", "${{ with.translated }}"]61        expression: "transpose | map(select(.[1] != null)) | map({path: .[0].path, text: .[1]})"6263  mirror:64    with:65      bundle: ${{ tasks.bundle.output }}66    for_each: ${{ with.bundle }}67    max_parallel: 868    ◆invoke:69      tool: "nika:write"70      args:71        path: "./i18n/${{ vars.lang }}/${{ item.path }}"72        content: "${{ item.text }}"73        create_dirs: true7475outputs:76  files:77    value: ${{ tasks.files.output }}78    description: "Every source file that was mirrored"79

lines 43–44: for_each: one run per doc, three in flight at a time. Source: the spec pack · 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.