Skip to content

Latest commit

 

History

History
263 lines (210 loc) · 12.7 KB

File metadata and controls

263 lines (210 loc) · 12.7 KB

@tangle-network/agent-runtime

The engine Tangle's AI agents run on. It runs an agent as a chat turn, a one-shot task, or a team of agents working toward a goal, records every run, and uses those records to measure and improve agents against real pass/fail checks.

One loop, used four common ways. Domain behavior (models, tools, knowledge) plugs in as adapters; the scoring statistics and the ship decision come from @tangle-network/agent-eval; sandboxed execution from @tangle-network/sandbox.

pnpm add @tangle-network/agent-runtime @tangle-network/agent-eval @tangle-network/sandbox

Contents

See it run in 30 seconds (offline, no keys): the one move everything else builds on, a driver reading a worker's output and composing the next step from it:

pnpm tsx examples/driver-loop/driver-loop.ts

What you do with it

You want to… Call
Run a chat turn for a production product agent handleChatTurn(...)
Have one agent supervise a team of agents toward a goal supervise(profile, task, opts)
Improve an agent and prove the gain on fresh tasks improve(profile, findings, opts)
Produce a measured knowledge-base candidate with agents and checks runKnowledgeImprovementJob(...)
Evaluate or train the same agent on PrimeIntellect createPrimeIntellectPackage(...)

Run a chat turn

A product agent is one handleChatTurn call inside a route. You give it how to produce the response and how to persist it; it streams, traces, and persists.

import { handleChatTurn } from '@tangle-network/agent-runtime'

const result = handleChatTurn({
  identity: { tenantId, sessionId: threadId, userId, turnIndex: 0 },
  hooks: {
    produce: () => ({ stream: box.streamPrompt(userMessage), finalText: () => box.lastResponse() }),
    persistAssistantMessage: async ({ identity, finalText }) => db.insertMessage(identity, finalText),
  },
  waitUntil,
})
return new Response(result.body, { headers: { 'content-type': result.contentType } })

Supervise a team of agents

One supervisor spawns and steers workers toward a goal. Where the workers run (an in-process loop, or a sandboxed coding harness) is one data value; the budget, journaling, and stopping are handled for you.

import { supervise } from '@tangle-network/agent-runtime/loops'

const result = await supervise(
  { name: 'supervisor', harness: null, systemPrompt: 'Delegate to workers; do not solve the task yourself.' },
  'Implement the feature and make the tests pass.',
  { budget, router, backend }, // backend = where workers run: router-tools | sandbox+harness | bridge
)

Improve an agent

improve optimizes one part of an agent and returns a detached winner plus a decision. The decision is ship only when the candidate beats the current agent on tasks it never practiced on. It accepts prompt, skill document, curated memory, tool, MCP, hook, subagent, whole-profile, and code surfaces through one call. Prompt, skill-document, and memory optimization have built-in generators; structured profile surfaces take an explicit generator, and code runs from isolated incumbent and candidate checkouts. Workflow and rollout-policy files use the code surface so the measured winner is an exact patch that can be sealed and executed; JSON parameter sweeps use agent-eval's parameterSweepProposer instead of a runtime-specific optimizer.

import { improve } from '@tangle-network/agent-runtime'

const { candidate, decision, lift } = await improve(baseProfile, findings, {
  surface: 'prompt',
  gate: 'holdout',
  scenarios,
  judge,
  agent,
})

if (decision === 'ship') console.log({ candidate, lift })

Skill and curated-memory candidates are exact profile changes, not free-floating text. Name one inline skill through skills.resourceName; curated memory uses profile.resources.instructions. Both require profile.resources.failOnError: true so an unsupported resource cannot silently disappear.

const skillResult = await improve(baseProfile, findings, {
  surface: 'skills',
  skills: { resourceName: 'incident-response' },
  scenarios, judge, agent,
})

improve is the search call. For production, proposeAgentImprovement adds trace analysis and reruns the exact frozen baseline and winner before creating a reviewable proposal. Runtime rejects a candidate bundle that differs from the search winner.

import {
  createAgentImprovementActivation,
  executeAgentImprovementActivation,
  proposeAgentImprovement,
  reviewAgentImprovementProposal,
} from '@tangle-network/agent-runtime/intelligence'

const result = await proposeAgentImprovement({
  runId,
  profile: liveProfile,
  analysis,
  improvement: { surface: 'prompt', scenarios, judge, agent },
  buildExperiment: ({ improvement }) => freezeExperiment(liveProfile, improvement.candidate),
  placeCell,
})

const review = reviewAgentImprovementProposal(result.proposal, {
  decision: 'approve',
  reviewedBy: user.id,
  reason: 'The measured gain is worth the cost.',
})
const activation = createAgentImprovementActivation(result.proposal, review, {
  intent: 'activate-candidate',
  targets: [{ surface: 'prompt', identity: profileId }],
  fundingOwner: tenantId,
  authorizedBy: user.id,
  expiresAt,
})
const outcome = await executeAgentImprovementActivation(
  { proposal: result.proposal, review, activation },
  { transition: commitProfileTransaction, reconcile: readCommittedResult },
)

freezeExperiment, placeCell, and the transaction functions are application ports because storage and compute differ by product. Runtime owns candidate identity, measurement, review binding, expiry, retry identity, and result validation; the application owns its atomic write.

Improve a knowledge base

runKnowledgeImprovementJob is the runtime-owned front door for KB, wiki, memory-backed, and RAG improvement jobs. It creates a candidate copy, runs supervised agents against it, checks readiness through @tangle-network/agent-knowledge, and returns frozen baseline and candidate snapshots with spend and timing. It never changes the live knowledge base. Use improve(..., { surface: 'memory' }) for the agent's curated lesson document; use this job for source, retrieval, and knowledge-store changes.

import { runKnowledgeImprovementJob } from '@tangle-network/agent-runtime/knowledge'

const result = await runKnowledgeImprovementJob({
  root: './kb',
  goal: 'Improve support refund-policy knowledge',
  readinessSpecs,
  budget: { maxIterations: 8, maxTokens: 120_000, maxUsd: 10 },
  backend,
})

console.log(result.knowledge?.reference.candidateHash, result.measurement.supervisedSpent)

Use it when the product needs one knob for "make this knowledge base better" instead of wiring improveKnowledgeBase, a runtime supervisor, candidate workspaces, and readiness checks by hand. Measure the returned bundle pair, record the review, then activate through executeAgentImprovementActivation; activation is the only write path.

Run on PrimeIntellect

@tangle-network/agent-runtime/primeintellect packages typed train and eval tasks as a Verifiers v1 environment. Prime launches your actual runtime program against an intercepted model endpoint, so runPersonified, runAgentic, product agents, tool calls, and multiple rounds stay intact. Reference answers remain in Prime's task process and never enter the agent workspace. The runner file must be one executable bundle containing the app and its runtime dependencies.

import { readFile } from 'node:fs/promises'
import {
  createPrimeIntellectPackage,
  writePrimeIntellectPackage,
} from '@tangle-network/agent-runtime/primeintellect'

const bundledRunner = await readFile('./dist/prime-runner.mjs', 'utf8')
const bundle = createPrimeIntellectPackage({
  name: 'support-agent-v1',
  version: '1.0.0',
  tasks: [
    {
      id: 'train-refund-policy',
      split: 'train',
      prompt: 'Can a subscription renewal be refunded?',
      answer: 'No',
    },
    {
      id: 'eval-final-sale',
      split: 'eval',
      prompt: 'Can a final-sale order be refunded?',
      answer: 'No',
    },
  ],
  scoring: { kind: 'exact', normalization: 'trim-casefold' },
  runner: {
    image: 'node:22-bookworm-slim',
    files: { 'runner.mjs': bundledRunner },
    command: ['node', 'runner.mjs'],
  },
})

await writePrimeIntellectPackage(bundle, './prime/support-agent-v1')

The runner reads the episode and uses the normal runtime APIs: Here, runProductAgent is the application's existing entry point, not another loop supplied by this adapter.

import {
  createPrimeIntellectBackend,
  runPrimeIntellectProgram,
} from '@tangle-network/agent-runtime/primeintellect'

await runPrimeIntellectProgram(async (episode) => {
  const backend = createPrimeIntellectBackend(episode)
  return runProductAgent({ task: episode.task, backend })
})

Prime writes complete traces.jsonl rows. Use importPrimeIntellectTraces(...) to convert them to agent-eval RunRecords for the existing reports and release checks.

How it works (the short version)

  • One agent, run two ways. The same agent runs at "do the task" speed and at "get better at the task" speed. "Driver", "worker", and "coordinator" are roles one agent plays, not separate types.
  • Everything is measured. Every run is a trace: tokens, dollars, time, and a pass/fail score from a real check. "Better" is a number with a denominator, not a vibe, and "equally good but cheaper" is a result you can prove.
  • Improvement is gated. A change ships only after it beats the current agent on fresh tasks no tuning step ever saw, with a statistical test, not a single lucky run.
  • The grader is honest. Whatever gives feedback never sees the answer key, and scores are recomputed from the attempts actually run. An agent cannot fabricate its own win.

Examples

Runnable, grouped by what they show. Copy the one nearest your task:

Do this Example
Run a product chat turn chat-handler
Drive a team of agents to a goal supervise · recursive-supervisor
Benchmark strategies on your own domain coding-benchmark
Benchmark harnesses × models over a real task suite (the real WebCode dataset) webcode-matrix
Render a multi-profile leaderboard with ranked board, score matrix, and SVG/HTML charts leaderboard(records)renderLeaderboardMarkdown / Svg / Html
Trace + bill + effort-gate the WebCode benchmark (the Intelligence SDK) intelligence-webcode
Self-improve an agent, gated on a held-out set improve · self-improving-coder
Improve a KB, wiki, or RAG corpus with runtime agents docs/canonical-api.md
Evaluate or train a runtime program on PrimeIntellect @tangle-network/agent-runtime/primeintellect
Study coordination vs raw compute ablation-suite

All 28 live in examples/.

Where to go next

  • New here? docs/concepts.md, the mental model in plain terms.
  • docs/canonical-api.md, find the primitive: "I want to ___ → use ___".
  • docs/api/primitive-catalog.md, every export in one generated, never-stale list with its import path. Check it before building anything new.
  • Import subpaths: the root export is the product surface (handleChatTurn, improve); deeper capabilities ship as subpaths: /loops (multi-agent + the loop kernel), /conversation (multi-turn conversations), /knowledge (KB improvement), /primeintellect (Prime task, runtime, and trace adapter), /mcp (tool servers), /intelligence (observability drop-in), /testing (validated fixture records for consumer tests), /agent, /profiles, /platform, /analyst-loop, /environment-provider.
  • docs/architecture.md, the design, end to end.
  • bench/HARNESS.md, the experiment harness and how to run a benchmark.

Contributing: pnpm i && pnpm test gets you running; the full local gate is the package.json scripts (lint, typecheck, docs:check).