Worker-Agent Integration Skill
Intelligent coordination between background workers and specialized agents.
Quick Start
View agent recommendations for a trigger
npx agentic-flow workers agents ultralearn npx agentic-flow workers agents optimize
View performance metrics
npx agentic-flow workers metrics
View integration stats
npx agentic-flow workers stats --integration
Agent Mappings
Workers automatically dispatch to optimal agents based on trigger type:
Trigger Primary Agents Fallback Pipeline Phases
ultralearn
researcher, coder planner discovery → patterns → vectorization → summary
optimize
performance-analyzer, coder researcher static-analysis → performance → patterns
audit
security-analyst, tester reviewer security → secrets → vulnerability-scan
benchmark
performance-analyzer coder, tester performance → metrics → report
testgaps
tester coder discovery → coverage → gaps
document
documenter, researcher coder api-discovery → patterns → indexing
deepdive
researcher, security-analyst coder call-graph → deps → trace
refactor
coder, reviewer researcher complexity → smells → patterns
Performance-Based Selection
The system learns from execution history to improve agent selection:
// Agent selection considers: // 1. Quality score (0-1) // 2. Success rate // 3. Average latency // 4. Execution count
const { agent, confidence, reasoning } = selectBestAgent('optimize'); // agent: "performance-analyzer" // confidence: 0.87 // reasoning: "Selected based on 45 executions with 94.2% success"
Memory Key Patterns
Workers store results using consistent patterns:
{trigger}/{topic}/{phase}
Examples:
- ultralearn$auth-module$analysis
- optimize$database$performance
- audit$payment$vulnerabilities
- benchmark$api$metrics
Benchmark Thresholds
Agents are monitored against performance thresholds:
{ "researcher": { "p95_latency": "<500ms", "memory_mb": "<256MB" }, "coder": { "p95_latency": "<300ms", "quality_score": ">0.85" }, "security-analyst": { "scan_coverage": ">95%", "p95_latency": "<1000ms" } }
Feedback Loop
Workers provide feedback for continuous improvement:
import { workerAgentIntegration } from 'agentic-flow$workers$worker-agent-integration';
// Record execution feedback workerAgentIntegration.recordFeedback( 'optimize', // trigger 'coder', // agent true, // success 245, // latency ms 0.92 // quality score );
// Check compliance const { compliant, violations } = workerAgentIntegration.checkBenchmarkCompliance('coder');
Integration Statistics
$ npx agentic-flow workers stats --integration
Worker-Agent Integration Stats ══════════════════════════════ Total Agents: 6 Tracked Agents: 4 Total Feedback: 156 Avg Quality Score: 0.89
Model Cache Stats ───────────────── Hits: 1,234 Misses: 45 Hit Rate: 96.5%
Configuration
Enable integration features in .claude$settings.json :
{ "workers": { "enabled": true, "parallel": true, "memoryDepositEnabled": true, "agentMappings": { "ultralearn": ["researcher", "coder"], "optimize": ["performance-analyzer", "coder"] } } }