@getmarrow/sdk
v3.7.28
Published
Your go-to memory provider for all agents, for any AI model.
Downloads
4,908
Maintainers
Readme
@getmarrow/sdk
Memory and decision intelligence for agents that need to get better over time.
Most agents still work like this:
- they plan something
- they do something
- they forget what happened
- then they repeat the same mistake next session
That's fine for a toy. It's a problem for anything real.
@getmarrow/sdk gives your agent a memory that compounds. It lets you log intent before meaningful work, pull back useful decision intelligence, and commit the outcome afterward so the next run starts smarter instead of blank.
Marrow turns agent memory from a passive log into an operating loop.
Start Here
For most agents and new users, start with the universal installer:
npx @getmarrow/install --yesThe installer detects your environment, wires MCP hooks or SDK passive runtime files where appropriate, runs a self-test, and shows first-run value proof.
Use this SDK directly when you are building a custom Node/TypeScript agent integration, want programmatic control, or need to wrap your own tools, commands, deploys, publishes, fetch calls, and guarded actions in code.
For MCP-native clients that need manual setup, use @getmarrow/mcp.
Auto-Logging
Marrow can log at three layers, but the behavior depends on how you wire it up:
| Layer | How | Agent effort |
|-------|-----|-------------|
| Server-side | Authenticated Marrow API calls are auto-logged server-side | Zero |
| SDK | createPassiveRuntime(), runGuarded(), think() / commit() after install/wrapping | Minimal |
| MCP hooks | npx @getmarrow/mcp setup — PostToolUse + UserPromptSubmit hooks after setup | Minimal |
Passive mode for SDK: Use marrow.createPassiveRuntime() once in the agent process, then install or wrap the surfaces you want covered. It can wrap global fetch, guard tools, commands, deploys, and publishes with the full Marrow loop. Use autoWrap() and wrapFetch() when you need lower-level control.
Disable passive: skip wrapping. Debug: check decision_id on returned objects.
Improvement Since Onboarding
Every dashboard and digest call now returns an improvement block comparing your agents' current performance against their day-1 baseline, captured automatically when an account reaches 7 days of activity or 20 decisions, whichever comes first.
const dash = await marrow.dashboard();
if (dash.improvement.status === 'active') {
console.log(`Agents are ${Math.abs(dash.improvement.time_to_success_seconds.delta_pct)}% ${
dash.improvement.time_to_success_seconds.delta_pct < 0 ? 'faster' : 'slower'
} since onboarding (${dash.improvement.days_since_baseline} days ago).`);
}Four measured deltas: attempts_per_success, time_to_success_seconds, drift_rate, success_rate, each with baseline, current, and delta_pct.
No heuristics, no estimates. The baseline is a frozen snapshot of your agents' own first week. Everything is computed from real decision data. Token-usage savings estimates remain on the enterprise roadmap.
What's New in v3.7.25
v3.7.25 makes passive guarded work fail closed when Marrow cannot prove the outcome was captured:
runGuarded()andcreatePassiveRuntime()callagentRuntime()before execution by default, so status, risk gate, lessons, templates, proof requirements, and exact next action arrive in one pre-action call.runGuarded()now requires outcome closure by default. If execution succeeds but the Marrow outcome commit fails, the guarded result returnsok: false,failure_type: "outcome_commit_failed", and the original result for inspection.- Passive tools, commands, deploys, and publishes pass
requireOutcomeClosure: trueautomatically. runGuarded()returnsoutcome_closure_required,outcome_closed,outcome_commit_error, andbefore_action_enforcedso agents can avoid falsely marking work complete.quickStatus()exposes outcome-eligible closure coverage, repair commands, and hook diagnostics so agents can tell exactly what is degraded and how to fix it without status/runtime guidance calls lowering coverage.agentRuntime()responses includebefore_you_act_injection, a structured fleet lesson/playbook signal agents can apply before acting.
const runtime = await marrow.agentRuntime({
action: 'deploy Cloudflare Worker to production',
type: 'deploy',
role: 'deploy',
surfaces: ['github', 'cloudflare', 'production']
});
const result = await marrow.runGuarded({
action: 'deploy Cloudflare Worker to production',
type: 'deploy',
role: 'deploy',
surfaces: ['github', 'cloudflare', 'production'],
riskPolicy: 'block_high',
includeValueReport: true,
execute: async () => deploy(),
});Full feature history, examples, and API reference live at getmarrow.ai/docs.
Human-Directed Attribution Status
The Marrow API supports privacy-preserving provenance fields on direct POST /v1/decisions calls: source_kind, human_directed, source_confidence, instruction_ref, instruction_hash, and source_meta. Use them to classify instruction source class without identifying the human or storing raw prompts/PII.
Current SDK passive runtime methods (think(), auto(), runGuarded(), and wrappers) remain backward compatible and do not yet expose first-class provenance parameters. SDK/MCP provenance wiring is deferred; do not assume SDK calls automatically mark work as human_directed. For direct API behavior and validation rules, see the live API reference at https://getmarrow.ai/docs.
Passive Runtime Layer v2
createPassiveRuntime() is for SDK agents that should benefit from Marrow after one install step.
const runtime = marrow.createPassiveRuntime({
mode: 'auto',
useWorkflowGate: true,
includeValueReport: true,
});
runtime.install(); // wraps global fetch when available
await runtime.deploy('deploy Cloudflare Worker to production', async () => {
return deploy();
}, {
surfaces: ['github', 'cloudflare', 'production']
});
await runtime.command('wrangler deploy', () => exec('wrangler deploy'));
await runtime.tool('github.pr.merge', () => mergePr());Each runtime surface auto-closes the outcome. Successful tool, command, deploy, and publish wrappers commit success; thrown errors commit failure with a redacted failure class. quickStatus() now exposes hookStatus, fixCommands, nextAction, outcomeEligibleDecisionCount, recentOutcomeEligibleDecisions24h, and autoOutcomeClosure so agents can repair degraded passive capture directly. Read-only status checks and one-call runtime guidance are not counted as outcome-eligible actions.
const status = await marrow.quickStatus();
if (status.health === 'degraded' && status.nextAction) {
console.log(status.nextAction); // e.g. npx @getmarrow/install --yes
}The runtime redacts URL/action metadata before logging, and Marrow never receives request bodies, headers, response bodies, or command output from this shim. Avoid placing secrets directly in action or command text when you can; the runtime redacts common cases but should not be treated as a license to inline credentials.
Guarded Run: One Passive Workflow Call
runGuarded() gives SDK agents the full Marrow loop in one call: decision brief, intent log, execution, outcome commit, failure classification, and optional owner-ready value report.
const guarded = await marrow.runGuarded({
action: 'deploy Cloudflare Worker to production',
type: 'deploy',
role: 'deploy',
surfaces: ['github', 'cloudflare', 'production'],
includeValueReport: true,
execute: async () => deploy(),
});
if (!guarded.ok) {
console.log(guarded.failure_type);
console.log(guarded.summary);
}Set riskPolicy: 'block_high' when the agent should stop before execution if Marrow classifies the work as high risk or the workflow gate requires review.
Value Report
Agents can now pull no-dashboard proof directly:
const report = await marrow.valueReport('7d');
console.log(report.summary);The report returns aggregate metrics, saves, fleet activity, top risks, recommendations, and improvement data without exposing raw decision text.
Decision Brief: One Pre-Action Call
Agents can call decisionBrief() before meaningful work to get risk, workflow, handoff, freshness, quality checks, source-of-truth surfaces, proof-pack requirements, and next actions in one backend call.
const brief = await marrow.decisionBrief({
action: 'publish SDK and MCP packages to npm and update docs',
type: 'deploy',
role: 'deploy',
surfaces: ['github', 'npm', 'docs', 'production']
});
if (brief.risk.level === 'high') {
console.log(brief.workflow.steps);
console.log(brief.quality.minimum_checks);
}Use this before deploys, publishes, merges, audits, patches, secret changes, or production work. Prior failure data is aggregated by type only; no raw action, context, or outcome text from past decisions is returned.
decisionBrief() does not replace the Marrow loop. Agents should still log intent with think() or passive auto-logging before acting, then call commit() after verification so the outcome teaches the next run.
Full feature history, examples, and API reference live at getmarrow.ai/docs.
Agent-Narrated Milestones
commit() returns a narrative field. When a milestone fires (first commit, baseline capture, decision #100/500/1000/5000, or a meaningful weekly recap), the backend returns a human-readable string the agent can relay to the user. Otherwise returns null.
Example:
const result = await marrow.commit({ success: true, outcome: 'Deploy succeeded' });
if (result.narrative) { console.log('Marrow:', result.narrative); }Narratives are pure aggregated metrics, no user data, no decision content. No heuristics.
Passive Mode
Four patterns for auto-logging agent decisions — pick what fits your runtime.
Process-level: createPassiveRuntime()
const runtime = marrow.createPassiveRuntime();
runtime.install();
await runtime.tool('linear.issue.update', () => updateIssue());
await runtime.command('npm publish', () => publishPackage(), {
role: 'deploy',
surfaces: ['npm', 'production']
});Use this when you own the agent process and want Marrow to sit behind common surfaces with minimal agent code. The runtime defaults the client to mode: 'auto' so installed/wrapped fetch calls and runtime actions log intent and outcomes automatically.
Per-function: wrap(meta, fn)
await marrow.wrap(
{ action: 'deploy release', type: 'process', external: true },
() => deploy()
);Per-object: autoWrap(client)
const wrappedAgent = marrow.autoWrap(myAgent, {
actionPrefix: 'claims-agent: ',
exclude: ['getConfig', 'toJSON'],
type: 'process',
});
await wrappedAgent.deploy();Per-fetch: wrapFetch(fetch)
const wrappedFetch = marrow.wrapFetch(fetch);
await wrappedFetch('https://api.example.com/deploy?token=secret', {
method: 'POST',
});Pairs with @getmarrow/mcp setup hooks. MCP users only get passive behavior after hook setup; SDK users get it after installing or wrapping the surfaces they want with createPassiveRuntime(), runGuarded(), autoWrap(), and wrapFetch().
Operator Dashboard
One call returns everything an operator needs to see — account health, top failures, workflow status, recent activity, and Marrow's impact.
const dash = await marrow.dashboard();
// dash.health.overall_score, dash.top_failures, dash.impact.saves_this_week, ...Weekly Digest
Periodic summary with success rate trend vs previous period.
const digest = await marrow.digest('7d');
// digest.summary, digest.success_rate.direction, digest.saves.count, ...Agent Status
Machine-readable proof that Marrow is installed, active, and collecting enough signal for an agent or fleet.
const status = await marrow.agentStatus('7d');
// status.active, status.state, status.signals.outcome_coverage, status.next_actions
const jarvis = await marrow.agentStatus('7d', 'jarvis-agent');States: inactive, warming_up, needs_outcomes, learning, proving_value.
Decision Brief
One pre-action bundle for agents. Instead of stitching together status, workflow, fleet, source-of-truth, and reporting calls, use decisionBrief() before meaningful work.
const brief = await marrow.decisionBrief({
action: 'deploy production worker',
type: 'deploy',
surfaces: ['github', 'production', 'docs']
});
// brief.risk.level, brief.workflow.steps, brief.handoff.required,
// brief.quality.minimum_checks, brief.proof_pack.fields, brief.next_actionsAfter reading the brief, continue the normal loop: log intent, do the work, verify, and commit the outcome.
Session Management
Explicit Session End
Gracefully close a session and optionally auto-commit any open decision — prevents orphaned decisions.
await marrow.endSession(true); // true = auto-commit any open decisionAuto-Workflow Detection
When Marrow detects a recurring decision sequence (5+ occurrences), it surfaces it in orient() as a suggestion. Accept it to convert the pattern into an enforced workflow.
await marrow.acceptDetectedWorkflow(detectedId);Intelligence Fields in think() Response
onboarding_hint— contextual tip for new accounts (first 50 decisions)intelligence.collective— anonymized insights aggregated from all Marrow accounts (k-anonymity ≥5)intelligence.team_context— recent decisions from other sessions in the same account
Velocity Metrics
Dashboard and digest now include three measured velocity metrics so operators can see how agents get better over time:
attempts_per_success— average number of decisions an agent makes before landing a successtime_to_success_seconds— median seconds fromthink()to successfulcommit()drift_rate— % of decisions that didn't link to a known pattern (lower = more reuse, less rediscovery)
Each metric reports {current, previous, delta_pct, direction} so trends are visible at a glance.
const dash = await marrow.dashboard();
console.log(dash.velocity.attempts_per_success.direction); // 'improving'
console.log(dash.velocity.time_to_success_seconds.current); // 47All metrics are computed from real decision data, no estimates, no heuristics. Token-usage savings are on the enterprise roadmap.
Available Templates
24 pre-built workflow templates across 8 industries. Browse via listTemplates() and install with installTemplate(slug).
- Insurance (4):
claims-triage,fraud-review,underwriting-decision,complaint-escalation - Healthcare (4):
patient-triage,clinical-documentation,prior-authorization,coding-audit - E-commerce (3):
order-fulfillment,refund-approval,return-processing - Legal (3):
contract-review,case-triage,document-discovery - SaaS (6):
code-review-deploy,incident-response,feature-rollout,ticket-triage,escalation-flow,lead-qualify - Fintech (2):
etl-pipeline,approval-flow - Media (1):
content-publish - Enterprise (1):
change-management
Full catalog with descriptions: https://getmarrow.ai/docs/#template-marketplace
const templates = await marrow.listTemplates({ industry: 'insurance' });
const workflow = await marrow.installTemplate('claims-triage');Active Intelligence — Marrow Intervenes Before Mistakes
Auto-Warn on Orient
When you call orient({autoWarn: true}), Marrow scans your recent decisions and warns you BEFORE you start a task that recently failed:
const result = await marrow.orient({
task: "Fix authentication error",
autoWarn: true
});
// Returns warnings like:
// "⚠️ HIGH: This task type failed 4x with approach='retry-without-fix'.
// Try approach='apply-patch-first' (89% success rate)"Loop Detection on Think
When you call think({checkLoop: true}), Marrow detects if you're about to retry a failed approach and interrupts:
const decision = await marrow.think({
action: "Retry auth with method='internal'",
checkLoop: true
});
// Returns loop warnings:
// "🚨 LOOP DETECTED: You're retrying a failed approach.
// Previous failure: 'retry-without-fix' approach not supported.
// Suggested: Use 'apply-patch-first' approach instead."Rate Limiting
orient: 30 requests/minute per accountthink: 60 requests/minute per account- Automatic 429 responses when limit exceeded
Enhanced PII Protection
- Automatic stripping of emails, phone numbers, API keys from all responses
- Applied to
recentLessons,warnings, andoutcomefields - Deep object stripping for complex data structures
The Problem
Without durable decision memory:
- agents repeat bad calls
- successful patterns get lost
- work gets marked "done" without outcome context
- external actions happen with no structured trail
- every new session wastes time rediscovering what already failed
A bigger context window doesn't solve this. You need a system that remembers:
- what the agent was trying to do
- what it actually did
- whether it worked
- what pattern that should teach the next attempt
The Solution
Marrow gives you a simple SDK for decision memory and loop discipline.
With @getmarrow/sdk, your agent can:
- orient at session start
- think before meaningful action
- check whether the loop is still open
- wrap important actions so intent and outcome stay connected
- commit the result back into memory
That gives you a usable operating loop:
orient -> think -> act -> check -> commitNot just memory for memory's sake — memory that improves execution.
The value compounds with use. Each decision your agent logs makes the hive smarter — failure rates drop, patterns emerge, and the next session starts with real intelligence instead of a blank slate.
Install
Default path for new users:
npx @getmarrow/install --yesAdvanced SDK path for custom Node/TypeScript integrations:
npm install @getmarrow/sdkGet your API key at getmarrow.ai
Quick Start
import { createMarrowClient } from '@getmarrow/sdk';
const marrow = createMarrowClient(process.env.MARROW_API_KEY!);
await marrow.orient();
await marrow.think({ action: 'deploy to production', type: 'deployment' });
await deployToProduction();
await marrow.commit({ success: true, outcome: 'Deployed v2.8.0 — 0 errors' });Zero-Ceremony Mode
The simplest integration — one call handles everything:
import { marrowFromEnv } from '@getmarrow/sdk';
const marrow = marrowFromEnv(); // reads MARROW_API_KEY, defaults to auto mode
await marrow.run('deploy to production', async () => {
await deployToProduction();
});
// orient + think + commit fire automaticallyHow It Works
1. Orient
Start the session with context from prior decisions.
await marrow.orient();This gives the agent a cleaner starting point instead of acting cold.
2. Think
Log intent before meaningful work.
const decision = await marrow.think({
action: 'Deploy auth refactor to staging',
type: 'implementation',
});Now the work has a decision trail and Marrow can return relevant intelligence.
3. Act
Do the actual work.
For low-friction usage, wrap the action directly:
await marrow.wrap(
{
action: 'Call deployment API',
type: 'implementation',
external: true,
result: 'Staging deploy succeeded',
},
async () => deployToStaging()
);4. Commit
Close the loop with the outcome.
await marrow.commit({
success: true,
outcome: 'Staging deploy succeeded, running smoke tests',
});API Reference
Core Methods
orient(taskType?)
Call at session start. Returns failure warnings from your history.
think(params)
Log intent before acting. Returns pattern intelligence and recommendations.
commit(params)
Log the outcome after acting. Closes the decision loop.
run(description, fn, options?)
Zero-ceremony wrapper. Handles orient → think → commit automatically.
wrap(meta, fn)
Wrap any action to auto-log intent and outcome.
📖 Full API reference with request/response examples: https://getmarrow.ai/docs/#api-reference
Memory Methods
listMemories(params?)
List memories with optional filters (status, query, limit, agentId).
getMemory(id)
Get a single memory by ID.
updateMemory(id, patch)
Update memory text, tags, or metadata.
deleteMemory(id, meta?)
Soft delete a memory.
markOutdated(id, meta?)
Mark a memory as outdated.
supersedeMemory(id, replacement)
Atomically replace a memory with a new version.
shareMemory(id, options)
Share a memory with specific agents.
exportMemories(options?)
Export memories to JSON or CSV.
importMemories(options)
Import memories with merge (dedup) or replace mode.
retrieveMemories(query, params?)
Full-text search with filters.
📖 All memory, query, and operator endpoints: https://getmarrow.ai/docs/#api-reference
Environment Variables
| Variable | Required | Description |
|----------|----------|-------------|
| MARROW_API_KEY | Yes | Your API key from getmarrow.ai |
| MARROW_BASE_URL | No | Custom API URL (default: https://api.getmarrow.ai). Must use HTTPS. |
| MARROW_SESSION_ID | No | Session identifier for multi-agent setups |
License
MIT
Related Packages
- @getmarrow/install — Default front door for new users. Detects local agent/runtime surfaces, writes safe config, runs self-tests, and reports first-value proof.
- @getmarrow/mcp — MCP server for Claude Code, Claude Desktop, and other MCP-compatible clients. Provides the same memory features through the Model Context Protocol. Includes one-command agent setup for automatic Marrow usage.
📖 Full API reference with all endpoints: https://getmarrow.ai/docs/#api-reference
