Distributed AI Operating System
Queue v3.1 is not an "agent system" — it's a distributed AI operating system. The key difference: agents don't self-certify their work. An independent verifier checks every output before it counts as complete.
Verifier = Source of Truth
Agents = Execution Only
Agent receives task → Agent does work → Agent says "done" → System trusts it
Problems:
Agent receives task → Agent does work → Receipt with hash → INDEPENDENT VERIFIER checks → Only then: verified
Improvements:
The pipeline is STRICT — no skipping allowed.
Rule: If ANY stage is skipped → job = INVALID
| Stage | Agent | Capabilities Required |
|---|---|---|
| research_synthesis | Alice | research.web, research.analysis |
| structural_review | Bolt | content.editing, verify.structure |
| brand_polish | Bolt | content.writing, brand.voice |
| ops_validation | Bobby | ops.validation |
| render_pdf | Renderer | content.design, content.pdf_generation |
| verify_output | Verifier | verify.content, verify.technical |
| deliver_telegram | Bobby | comms.telegram |
Checks receipt has all required fields, stage sequence is valid, artifacts are present.
Failure → RETRY
Verifies hash chain (input_hash = previous output_hash), all artifacts exist on disk, artifact hashes match, no corrupted files.
Failure → RETRY
Confidence meets threshold (default: 0.80), quality score meets threshold (default: 70), no self-verification, required agents participated, acceptance criteria met.
Failure → ESCALATE (if high confidence) or RETRY (if low confidence)
| Decision | Condition | Action |
|---|---|---|
pass | All 3 layers pass | Mark verified, proceed to next stage |
retry | Layer 1 or 2 fail, or low confidence | Route back to agent with feedback |
fail | Policy violation, unrecoverable | Mark failed, notify human |
escalate | Quality issue with high confidence | Notify KJ for human review |
Each receipt contains:
input_hash — SHA-256 hash of previous stage's outputoutput_hash — SHA-256 hash of this stage's outputThis creates an immutable chain proving data integrity through the pipeline.
Stage 0 (research_synthesis): input_hash: null (first stage) output_hash: 978d2db1bda39957... Stage 1 (structural_review): input_hash: 978d2db1bda39957... ← Must match Stage 0 output output_hash: e47faacc674adc23... Stage 2 (brand_polish): input_hash: e47faacc674adc23... ← Must match Stage 1 output output_hash: d9af6735f71a90c2... ...and so on through all 7 stages
When routing a stage to an agent, the system calculates a score:
Score = (Capability Match × 0.40) +
(Success Rate × 0.30) +
(Quality Score × 0.20) +
(Load Balance × 0.10)
| Factor | Weight | Description |
|---|---|---|
| Capability Match | 40% | Does agent have required capabilities? (0 or 1) |
| Success Rate | 30% | Historical success % for this job type |
| Quality Score | 20% | Average quality score on completed jobs |
| Load Balance | 10% | Inverse of current load (prefer less loaded) |
Two agents try to claim the same job at the same time. Both think they got it. Double execution.
The Solution: Claim Locks
UPDATE jobs SET status = 'claimed', claimed_by = ?, claimed_at = ? WHERE id = ? AND status = 'dispatched'
Only ONE agent wins this race. The others get 0 rows affected.
A job is COMPLETE only when:
No shortcuts. No fake completions. No trust without verification.
| Service | Endpoint | LaunchAgent |
|---|---|---|
| Queue API | http://localhost:3334 | com.ftws.queue-v3 |
| Verifier API | http://localhost:3335 | com.ftws.verifier |
Auth Token: q3-v3-axon-fleet-2026
| Method | Endpoint | Purpose |
|---|---|---|
| GET | /health | Service status |
| POST | /jobs | Create new job |
| GET | /jobs | List jobs (with filters) |
| GET | /jobs/:id | Get job details + stages |
| PUT | /jobs/:id/state | Update job state |
| POST | /jobs/:id/claim | Claim job (concurrency lock) |
| POST | /receipts | Create receipt (submit work) |
| GET | /receipts/:id | Get receipt details |
| POST | /verifications | Create verification |
| GET | /agents | List agents |
| GET | /audit/:job_id | Get audit log |
curl -X POST http://localhost:3334/jobs \
-H "Authorization: Bearer q3-v3-axon-fleet-2026" \
-H "Content-Type: application/json" \
-d '{
"type": "report",
"priority": 7,
"from": "dispatcher",
"subject": "Q1 Marketing Report",
"body": "Generate Q1 marketing performance report",
"acceptance_criteria": {
"output_format": "pdf",
"required_sections": ["executive_summary", "recommendations"],
"min_confidence": 0.85,
"min_quality_score": 75
}
}'
Queue v3.1 transforms the FTWS agent fleet from a loose collection of workers into a coordinated, verified, audited operating system.
This is the foundation for scaling to government contracts and enterprise clients.