Marketplace mapreduce

The MapReduce skill enables parallel task execution across multiple AI providers or agent instances, followed by intelligent consolidation of results. This produces higher-quality outputs by levera...

install

source · Clone the upstream repo

git clone https://github.com/aiskillstore/marketplace

Claude Code · Install into ~/.claude/skills/

T=$(mktemp -d) && git clone --depth=1 https://github.com/aiskillstore/marketplace "$T" && mkdir -p ~/.claude/skills && cp -r "$T/skills/consiliency/mapreduce" ~/.claude/skills/aiskillstore-marketplace-mapreduce && rm -rf "$T"

manifest: skills/consiliency/mapreduce/SKILL.md

source content

MapReduce Skill

Skill ID: mapreduce Purpose: Fan-out tasks to multiple providers/agents, then consolidate results Category: Orchestration

Overview

Architecture

┌─────────────────────────────────────────────────────────────────────────┐
│                      MAIN THREAD (Orchestrator)                          │
│                                                                         │
│  ┌─────────────────────────────────────────────────────────────────┐    │
│  │  PHASE 1: MAP (Parallel Fan-Out)                                │    │
│  │                                                                 │    │
│  │  Task(worker-1) ──→ output-1.md                                │    │
│  │  Task(worker-2) ──→ output-2.md                                │    │
│  │  Task(worker-3) ──→ output-3.md                                │    │
│  │  bash(codex)   ──→ output-codex.md                             │    │
│  │  bash(gemini)  ──→ output-gemini.md                            │    │
│  └─────────────────────────────────────────────────────────────────┘    │
│                              │                                          │
│                              ▼                                          │
│  ┌─────────────────────────────────────────────────────────────────┐    │
│  │  PHASE 2: COLLECT (Timeout-Based)                               │    │
│  │                                                                 │    │
│  │  TaskOutput(worker-1, timeout=120s)                            │    │
│  │  TaskOutput(worker-2, timeout=120s)                            │    │
│  │  TaskOutput(worker-3, timeout=120s)                            │    │
│  │  Verify: output-codex.md, output-gemini.md exist               │    │
│  └─────────────────────────────────────────────────────────────────┘    │
│                              │                                          │
│                              ▼                                          │
│  ┌─────────────────────────────────────────────────────────────────┐    │
│  │  PHASE 3: REDUCE (Consolidation)                                │    │
│  │                                                                 │    │
│  │  Task(reducer) ──→ reads all outputs ──→ consolidated.md       │    │
│  └─────────────────────────────────────────────────────────────────┘    │
└─────────────────────────────────────────────────────────────────────────┘

Key Constraint

Subagents cannot spawn other subagents. All orchestration happens in the main thread. Workers and reducers are subagents that operate on files.

Use Cases

1. Parallel Planning

Fan out planning task to multiple providers with different strategic biases:

Workers:
  - planner-conservative: Low-risk, proven patterns
  - planner-aggressive: Fast-track, modern patterns
  - planner-security: Security-first approach

Reducer: plan-reducer
Output: specs/ROADMAP.md

See:

cookbook/parallel-planning.md

2. Multi-Implementation

Generate the same feature with multiple models, pick best:

Workers:
  - impl-claude: Claude's implementation
  - impl-codex: OpenAI's implementation
  - impl-gemini: Gemini's implementation

Reducer: code-reducer
Output: src/feature/implementation.ts

See:

cookbook/multi-impl.md

3. Debug Consensus

Get multiple diagnoses of a bug, verify and select best fix:

Workers:
  - debug-claude: Claude's diagnosis
  - debug-codex: Codex's diagnosis
  - debug-gemini: Gemini's diagnosis

Reducer: debug-reducer
Output: Applied fix + documentation

See:

cookbook/debug-consensus.md

Available Reducers

Reducer	Agent Path	Purpose
`plan-reducer`	`agents/orchestration/reducers/plan-reducer.md`	Consolidate plans
`code-reducer`	`agents/orchestration/reducers/code-reducer.md`	Compare/merge code
`debug-reducer`	`agents/orchestration/reducers/debug-reducer.md`	Verify fixes

Provider Integration

Claude Subagents (via Task tool)

Task(subagent_type="Plan", prompt="...", run_in_background=true)

External CLI Providers (via spawn skill)

# Codex
codex -m gpt-5.1-codex -a full-auto "${PROMPT}" > output.md

# Gemini
gemini -m gemini-3-pro "${PROMPT}" > output.md

# Cursor
cursor-agent --mode print "${PROMPT}" > output.md

# OpenCode
opencode --provider anthropic "${PROMPT}" > output.md

See:

skills/spawn/agent/cookbook/

for detailed CLI patterns.

File Conventions

All MapReduce operations follow standard file conventions:

Type	Location	Naming
Plan outputs	`specs/plans/`	`planner-{name}.md`
Code outputs	`implementations/`	`impl-{name}.{ext}`
Debug outputs	`diagnoses/`	`debug-{name}.md`
Consolidated	Specified in prompt	`ROADMAP.md` , `implementation.ts`

See:

reference/file-conventions.md

Scoring Rubrics

Each reducer uses a specific scoring rubric:

Plans: Completeness, Feasibility, Risk, Clarity, Innovation
Code: Correctness, Readability, Maintainability, Performance, Security
Debug: Correctness, Minimality, Safety, Clarity, Root Cause

See:

reference/scoring-rubrics.md

Commands

Command	Purpose
`/ai-dev-kit:mapreduce`	Full MapReduce workflow
`/ai-dev-kit:map`	Just the fan-out phase
`/ai-dev-kit:reduce`	Just the consolidation phase

Example: Full MapReduce

# In main thread:

## Step 1: MAP

Launch planners in a single message (enables parallelism):

Task(subagent_type="Plan", prompt="""
  Create implementation plan for: User Authentication
  Write to: specs/plans/planner-conservative.md
  Strategy: Conservative - proven patterns, minimal risk
""", run_in_background=true)

Task(subagent_type="Plan", prompt="""
  Create implementation plan for: User Authentication
  Write to: specs/plans/planner-aggressive.md
  Strategy: Aggressive - fast, modern patterns
""", run_in_background=true)

Bash("codex -m gpt-5.1-codex -a full-auto 'Create auth plan' > specs/plans/planner-codex.md")

## Step 2: COLLECT

TaskOutput(task_id=conservative-id, block=true, timeout=120000)
TaskOutput(task_id=aggressive-id, block=true, timeout=120000)

# Verify codex output exists
Read("specs/plans/planner-codex.md")

## Step 3: REDUCE

Task(subagent_type="ai-dev-kit:orchestration:plan-reducer", prompt="""
  Consolidate plans in specs/plans/*.md
  Output: specs/ROADMAP.md
  Priority: Security over speed
""")

Cookbook

```
parallel-planning.md
```
: Multi-provider planning workflows
```
multi-impl.md
```
: Code generation with selection
```
debug-consensus.md
```
: Multi-diagnosis bug fixing

Reference

```
scoring-rubrics.md
```
: Detailed scoring criteria
```
file-conventions.md
```
: Output file standards

Related Skills

```
spawn
```
: Provider-specific CLI invocation patterns
```
multi-agent-orchestration
```
: General multi-agent patterns
```
research
```
: Parallel research with synthesis