Previous: 108 EVOI Next-Step & CoT Next: 110 Bayesian Lift & N_eff

Stage 109aq109_ingest_harness_telemetryDB-UNIT-09Agent Fees, AFK Budget Holds, CPOP Review & Q12 Royalty Clearinghouse

Harness Telemetry

Atomic flat-row micro-queue with 0-call slot and 5-role pod.

Captures normalized client telemetry (harness_id, version, model_id, provider, personality_id, keywords, CoT, logs, latency, tokens, score) on every completion.

/components/ingest_harness_telemetry.json /components/ingest_harness_telemetry.md Open in Queue Commons

Inputs (Flat Row)

Completion telemetry payload from /v1/complete or /v1/swarm/cycle

Atomic Queue & Lanes

aq109_ingest_harness_telemetry
ledger-db.teleon.dev
Harness + Model ID
Tokens & Reasoning
Execution Logs & CoT

Execution Modes & Agent Freedom

Deterministic (0 calls): q12_ledger_and_cusum_engine_v1 (Secret-scrubbing telemetry normalizer & schema validator)
Hybrid (<=1 call): cpop_evidence_audit_summarizer_v1
AI Agent (1..6): cross_family_independent_reviewer_v1 (Failure-log summarizer & anomaly tagger; Instructions + Resources + Freedom to search for new resources and new ways not bound by instructions)

Outputs (Table Merge)

Sanitized harness_telemetry_record/v1 in Store S25

Modular 6-layer envelope & 0..32 Kleisli onion middlelayers (DB substrates exempt)

Inbound and outbound calls traverse versioned envelope layers and composable Kleisli middlelayers before reaching the swappable engine slot, while backing database kernels enforce 0 inline agent wrapper steps.

1. frustration_avoidance
2. flexible_pointer_or_slice_carrier
3. thp_schema_and_version_handshake
4. surface_account_and_ring_entitlement
5. idempotent_effect_journal_and_tracking
6. preflight_self_repair_and_zero_call_check
7. 0..32 Kleisli steps (shims / budget deadlines / secret scrub)
8. slot.aq109_ingest_harness_telemetry (Native | Pinned OSS | Wasm)
ACID DB Core: 0 agent wrapper steps

5-role component managing pod & engine-slot twins

0-Call Slot (R1_DET_ENGINE): Executes SQL, BM25F/Roaring, AST, or fuel-metered Wasm adapters behind a fixed typed engine_slot/v1, pairing pinned upstream OSS adapters with clean Teleon-native twins.
Solver+OpenSearch (R2_PRIMARY_SOLVER): Runs under Instructions + Resources + Freedom to search for new resources and new ways not bound by instructions on 1 self-contained depth-1 flat task row per lease.
Split-Supervisor (R3_QUEUE_SUPERVISOR): Watches queue depth, stalls, and context horizons; explodes oversized tasks into wave-ordered flat subtask rows while preserving the original parent intact for rollup verification and long-horizon benchmarking.
Repair+Shim (R4_DIAGNOSTIC_REPAIR): Reviews whether the edge contract itself failed before mutating code (LE-CONTRACT-002), repairs lease timeouts and schema mismatches, and synthesizes 0..32-step middlelayer shims.
CPOP+Distill (R5_VERIFIER_DISTILLER): Grades outputs across an independent model family (reviewer != producer) and distills recurring high-cost agent wins into 0-call deterministic Sister code.

Parent-preserving supervision, catch-all & optional SCD2 packs

Supervisor split (aq41): Oversized or stalled tasks split into wave-ordered subtask rows while keeping subdivided_parent intact for rollup verification and direct long-horizon benchmarks.
Optional SCD Type 2 packs (Store S12): Versioned pack_sk rows (valid_from_utc, valid_to_utc, is_current, edited_by) supply optional locales, settings, instructions, suggestion paths, and tools across bare_baseline, pre_materialized_flat, and on_demand_claim_hydrated modes.
Flexible carriers: inline_object, swhid_cas_pointer, http_206_byte_slice, d1_row_cursor, signed_r2_uri

Normalized tables, invariants & 1 flat task row

Cell host: ledger-db.teleon.dev
Backlog table: teleon_core.telemetry_royalty_todo_backlog
Hydration: Normalized supporting tables join server-side into 1 flat row on claim
teleon_core.agent_fee_tariffs
teleon_core.agent_fee_quotes_and_holds
teleon_core.agent_fee_settlement_splits
teleon_core.agent_fee_savings_evidence
teleon_core.agent_fee_csr_tax_ledger
teleon_core.cpop_orthogonal_review_verdicts
teleon_core.teleon_double_entry_royalty_journal

Ledger and fee-hold rows run under SERIALIZABLE ACID_COMMIT_KERNEL_POLICY with zero inline agent middleware.
A producer family never approves its own work (reviewer_family != producer_family).

Atomic micro-queue & Track 2 Sister objective

Atomic queue: aq109_ingest_harness_telemetry via q11-cpop-review-queue.teleon.dev
Track 2 Sister (SISTER-09): sq09-improve-ledger-queue.teleon.dev
Sister objective: Tune off-peak AFK discounts, Shapley/Q12 attribution weights, Hebbian decay, and CUSUM drift windows.

store:S25dimensions:6_factorssecret_scrubbed:true

Bot & harness fleet actions (Codex, Claude Code, ChatGPT, Dots, Meta Muse, GrokBot)

Record exact harness, model, personality, instruction pack, keywords, and context IDs per run
Track input, output, and reasoning token counts alongside latency_ms and outcome_score_0_100
Scrub any key-shaped strings before persisting execution logs or CoT traces

Sister self-tuning areas & HTTP queue submission

Tune off-peak AFK congestion discounts and 6-bucket Q12 royalty weights (DIM-08)
Calibrate Hebbian learning rate and CUSUM drift sensitivity on historical anomalies (DIM-01)
Add deterministic Sybil-collusion graph detectors (DIM-06)

# Zero-auth claim 1 flat-hydrated task row from this atomic micro-queue:
curl -sS "https://router.teleon.dev/v1/claim?agent=meta-muse&atomic_queue_id=aq109_ingest_harness_telemetry"
# Or enqueue a task directly onto this atomic micro-queue:
curl -sS https://queues.teleon.dev/v1/queues/submit \
  -H "Content-Type: application/json" \
  -d '{"atomic_queue_id":"aq109_ingest_harness_telemetry","db_unit_id":"DB-UNIT-09","title":"Task for ingest_harness_telemetry"}'