electric-sql · KyleAMathews · May 21, 2026 · May 21, 2026
diff --git a/.changeset/update-agent-package-dependencies.md b/.changeset/update-agent-package-dependencies.md
@@ -0,0 +1,8 @@
+---
+"@electric-ax/agents-runtime": patch
+"@electric-ax/agents-server-conformance-tests": patch
+"@electric-ax/agents-server": patch
+"@electric-ax/agents": patch
+---
+
+Move agent runtime integrations from the deprecated `@mariozechner` packages to the new `@earendil-works` packages and refresh related dependency metadata.
diff --git a/examples/agents-chat-starter/package.json b/examples/agents-chat-starter/package.json
@@ -10,17 +10,17 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@durable-streams/state": "npm:@electric-ax/durable-streams-state-beta@^0.3.0",
-    "@electric-ax/agents-runtime": "^0.0.4",
-    "@mariozechner/pi-agent-core": "^0.57.1",
+    "@durable-streams/state": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/state@5d5c217",
+    "@electric-ax/agents-runtime": "workspace:*",
     "@radix-ui/react-icons": "^1.3.0",
     "@radix-ui/themes": "^3.3.0",
     "@sinclair/typebox": "^0.34.0",
     "@tanstack/db": "^0.6.0",
     "@tanstack/react-db": "^0.1.78",
     "react": "^19.2.4",
     "react-dom": "^19.2.4",
-    "zod": "^4.3.6"
+    "zod": "^4.3.6",
+    "@earendil-works/pi-agent-core": "^0.75.4"
   },
   "devDependencies": {
     "@types/react": "^19.2.14",

diff --git a/examples/deep-survey/package.json b/examples/deep-survey/package.json
@@ -11,17 +11,17 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@durable-streams/state": "npm:@electric-ax/durable-streams-state-beta@^0.3.0",
+    "@durable-streams/state": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/state@5d5c217",
     "@electric-ax/agents-runtime": "workspace:*",
-    "@mariozechner/pi-agent-core": "^0.70.2",
     "@radix-ui/themes": "^3.3.0",
     "@sinclair/typebox": "^0.34.0",
     "@tanstack/db": "^0.6.0",
     "@tanstack/react-db": "^0.1.78",
     "d3-force": "^3.0.0",
     "react": "^19.2.4",
     "react-dom": "^19.2.4",
-    "zod": "^4.3.6"
+    "zod": "^4.3.6",
+    "@earendil-works/pi-agent-core": "^0.75.4"
   },
   "devDependencies": {
     "@types/d3-force": "^3.0.0",

diff --git a/examples/deep-survey/src/server/orchestrator.ts b/examples/deep-survey/src/server/orchestrator.ts
@@ -7,7 +7,7 @@ import { db } from '@electric-ax/agents-runtime'
 import { queryOnce } from '@durable-streams/state'
 import { Type } from '@sinclair/typebox'
 import { exec, execFile } from 'node:child_process'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 import { swarmSharedSchema, type WikiEntry, type Xref } from './schema.js'
 import { explorerSpawnArgs } from './explorer.js'
 import { SURVEY_WORKER_ENTITY_TYPE } from './survey-worker.js'

diff --git a/packages/agents-runtime/package.json b/packages/agents-runtime/package.json
@@ -83,8 +83,6 @@
     "@anthropic-ai/sdk": "^0.78.0",
     "@durable-streams/client": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/client@5d5c217",
     "@durable-streams/state": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/state@5d5c217",
-    "@mariozechner/pi-agent-core": "^0.70.2",
-    "@mariozechner/pi-ai": "^0.70.2",
     "@mozilla/readability": "^0.6.0",
     "@sinclair/typebox": "^0.34.48",
     "@standard-schema/spec": "^1.1.0",
@@ -97,7 +95,9 @@
     "turndown": "^7.2.2",
     "turndown-plugin-gfm": "^1.0.2",
     "zod": "^4.3.6",
-    "zod-to-json-schema": "^3.25.2"
+    "zod-to-json-schema": "^3.25.2",
+    "@earendil-works/pi-agent-core": "^0.75.4",
+    "@earendil-works/pi-ai": "^0.75.4"
   },
   "devDependencies": {
     "@durable-streams/server": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/server@5d5c217",

diff --git a/packages/agents-runtime/src/model-runner.ts b/packages/agents-runtime/src/model-runner.ts
@@ -1,9 +1,9 @@
 import { readFileSync } from 'node:fs'
 import { homedir } from 'node:os'
 import { join } from 'node:path'
-import { completeSimple, getModel } from '@mariozechner/pi-ai'
+import { completeSimple, getModel } from '@earendil-works/pi-ai'
 import type { AgentConfig } from './types'
-import type { KnownProvider } from '@mariozechner/pi-ai'
+import type { KnownProvider } from '@earendil-works/pi-ai'
 
 export interface LowCostModelChoice {
   provider: KnownProvider | string

diff --git a/packages/agents-runtime/src/pi-adapter.ts b/packages/agents-runtime/src/pi-adapter.ts
@@ -7,8 +7,8 @@
  * - Delegating ID management and event writing to OutboundBridge
  */
 
-import { Agent } from '@mariozechner/pi-agent-core'
-import { getModel } from '@mariozechner/pi-ai'
+import { Agent } from '@earendil-works/pi-agent-core'
+import { getModel } from '@earendil-works/pi-ai'
 import { createOutboundBridge } from './outbound-bridge'
 import { runtimeLog } from './log'
 import type { OutboundIdSeed } from './outbound-bridge'
@@ -18,12 +18,12 @@ import type {
   AgentMessage,
   AgentTool,
   StreamFn,
-} from '@mariozechner/pi-agent-core'
+} from '@earendil-works/pi-agent-core'
 import type {
   KnownProvider,
   Model,
   SimpleStreamOptions,
-} from '@mariozechner/pi-ai'
+} from '@earendil-works/pi-ai'
 import type { LLMMessage } from './types'
 
 // ============================================================================
@@ -89,9 +89,16 @@ export function toAgentHistory(
   const history: Array<AgentMessage> = []
   const toolNamesById = new Map<string, string>()
 
-  const lastAssistant = (): AgentMessage | undefined => {
+  const lastAssistant = ():
+    | (AgentMessage & { role: `assistant`; content: Array<unknown> })
+    | undefined => {
     const last = history[history.length - 1]
-    return last?.role === `assistant` ? last : undefined
+    return last?.role === `assistant`
+      ? (last as AgentMessage & {
+          role: `assistant`
+          content: Array<unknown>
+        })
+      : undefined
   }
 
   for (const message of messages) {

diff --git a/packages/agents-runtime/src/tools/bash.ts b/packages/agents-runtime/src/tools/bash.ts
@@ -1,6 +1,6 @@
 import { exec } from 'node:child_process'
 import { Type } from '@sinclair/typebox'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 
 const TIMEOUT_MS = 30_000
 const MAX_OUTPUT_CHARS = 50_000

diff --git a/packages/agents-runtime/src/tools/brave-search.ts b/packages/agents-runtime/src/tools/brave-search.ts
@@ -1,6 +1,6 @@
 import Anthropic from '@anthropic-ai/sdk'
 import { Type } from '@sinclair/typebox'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 
 const BRAVE_API_URL = `https://api.search.brave.com/res/v1/web/search`
 const SEARCH_FALLBACK_MODEL = `claude-haiku-4-5-20251001`

diff --git a/packages/agents-runtime/src/tools/edit.ts b/packages/agents-runtime/src/tools/edit.ts
@@ -3,7 +3,7 @@ import { relative, resolve } from 'node:path'
 import { createTwoFilesPatch } from 'diff'
 import { Type } from '@sinclair/typebox'
 import { runtimeLog } from '../log'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 
 const READ_GUARD_MESSAGE = (rel: string): string =>
   `File ${rel} has not been read in this session (sessions are per-wake — re-read after waking from a worker).`

diff --git a/packages/agents-runtime/src/tools/fetch-url.ts b/packages/agents-runtime/src/tools/fetch-url.ts
@@ -4,7 +4,7 @@ import { Readability } from '@mozilla/readability'
 import { JSDOM, VirtualConsole } from 'jsdom'
 import TurndownService from 'turndown'
 import { completeWithLowCostModel } from '../model-runner'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 import type { LowCostModelCatalog, LowCostModelConfig } from '../model-runner'
 
 const MAX_RAW_CHARS = 100_000

diff --git a/packages/agents-runtime/src/tools/read-file.ts b/packages/agents-runtime/src/tools/read-file.ts
@@ -2,7 +2,7 @@ import { readFile, stat } from 'node:fs/promises'
 import { relative, resolve } from 'node:path'
 import { Type } from '@sinclair/typebox'
 import { runtimeLog } from '../log'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 
 const MAX_FILE_SIZE = 512 * 1024 // 512 KB
 

diff --git a/packages/agents-runtime/src/tools/schedules.ts b/packages/agents-runtime/src/tools/schedules.ts
@@ -1,7 +1,7 @@
 import { randomUUID } from 'node:crypto'
 import { Type } from '@sinclair/typebox'
 import { runtimeLog } from '../log'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 import type { EntityStreamDBWithActions } from '../entity-stream-db'
 
 type ScheduleManifest = {

diff --git a/packages/agents-runtime/src/tools/write.ts b/packages/agents-runtime/src/tools/write.ts
@@ -3,7 +3,7 @@ import { dirname, relative, resolve } from 'node:path'
 import { createTwoFilesPatch } from 'diff'
 import { Type } from '@sinclair/typebox'
 import { runtimeLog } from '../log'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 
 export function createWriteTool(
   workingDirectory: string,

diff --git a/packages/agents-runtime/src/types.ts b/packages/agents-runtime/src/types.ts
@@ -22,12 +22,12 @@ import type {
 import type {
   AgentTool as PiAgentTool,
   StreamFn,
-} from '@mariozechner/pi-agent-core'
+} from '@earendil-works/pi-agent-core'
 import type {
   KnownProvider,
   Model,
   SimpleStreamOptions,
-} from '@mariozechner/pi-ai'
+} from '@earendil-works/pi-ai'
 import type {
   EntityStreamDB as RuntimeEntityStreamDB,
   EntityStreamDBWithActions as RuntimeEntityStreamDBWithActions,

diff --git a/packages/agents-runtime/test/model-runner.test.ts b/packages/agents-runtime/test/model-runner.test.ts
@@ -3,7 +3,7 @@ import { beforeEach, describe, expect, test, vi } from 'vitest'
 const completeSimple = vi.fn()
 const getModel = vi.fn(() => ({ provider: `openai-codex`, id: `gpt-5.4-mini` }))
 
-vi.mock(`@mariozechner/pi-ai`, () => ({ completeSimple, getModel }))
+vi.mock(`@earendil-works/pi-ai`, () => ({ completeSimple, getModel }))
 
 const { completeWithLowCostModel } = await import(`../src/model-runner`)
 

diff --git a/packages/agents-runtime/test/pi-adapter.test.ts b/packages/agents-runtime/test/pi-adapter.test.ts
@@ -12,7 +12,7 @@ import type {
   Model,
   ToolResultMessage,
   UserMessage,
-} from '@mariozechner/pi-ai'
+} from '@earendil-works/pi-ai'
 
 interface PiAgentAdapterConfig {
   entityUrl: string

diff --git a/packages/agents-server-conformance-tests/package.json b/packages/agents-server-conformance-tests/package.json
@@ -48,9 +48,9 @@
   },
   "devDependencies": {
     "@electric-ax/agents-server": "workspace:*",
-    "@mariozechner/pi-agent-core": "^0.70.2",
     "tsdown": "^0.9.0",
-    "typescript": "^5.0.0"
+    "typescript": "^5.0.0",
+    "@earendil-works/pi-agent-core": "^0.75.4"
   },
   "engines": {
     "node": ">=18.0.0"

diff --git a/packages/agents-server-conformance-tests/src/mock-stream.ts b/packages/agents-server-conformance-tests/src/mock-stream.ts
@@ -1,4 +1,4 @@
-import type { StreamFn } from '@mariozechner/pi-agent-core'
+import type { StreamFn } from '@earendil-works/pi-agent-core'
 
 export function createMockStreamFn(text: string): StreamFn {
   return () => {

diff --git a/packages/agents-server/package.json b/packages/agents-server/package.json
@@ -50,7 +50,6 @@
     "@durable-streams/state": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/state@5d5c217",
     "@electric-ax/agents-runtime": "workspace:*",
     "@electric-sql/client": "^1.5.18",
-    "@mariozechner/pi-agent-core": "^0.70.2",
     "@opentelemetry/api": "^1.9.1",
     "@sinclair/typebox": "^0.34.48",
     "@whatwg-node/server": "^0.10.18",
@@ -63,7 +62,8 @@
     "pino": "^10.3.1",
     "pino-pretty": "^13.0.0",
     "postgres": "^3.4.0",
-    "undici": "^7.24.7"
+    "undici": "^7.24.7",
+    "@earendil-works/pi-agent-core": "^0.75.4"
   },
   "devDependencies": {
     "@electric-ax/agents": "workspace:*",

diff --git a/packages/agents-server/src/electric-agents/adapter-types.ts b/packages/agents-server/src/electric-agents/adapter-types.ts
@@ -5,7 +5,7 @@
  * SDK events into State Protocol writes via the provided writeEvent callback.
  */
 
-import type { AgentTool, StreamFn } from '@mariozechner/pi-agent-core'
+import type { AgentTool, StreamFn } from '@earendil-works/pi-agent-core'
 
 /** A State Protocol event to be written via the adapter's writeEvent callback. */
 export interface WriteEvent {

diff --git a/packages/agents-server/src/server.ts b/packages/agents-server/src/server.ts
@@ -22,7 +22,7 @@ import { serverLog } from './utils/log.js'
 import type { DrizzleDB, PgClient } from './db/index.js'
 import type { Server } from 'node:http'
 import type { DurableStreamTestServer } from '@durable-streams/server'
-import type { StreamFn } from '@mariozechner/pi-agent-core'
+import type { StreamFn } from '@earendil-works/pi-agent-core'
 import type {
   AgentModel,
   EntityRegistry,

diff --git a/packages/agents-server/test/horton-pull-wake-e2e.test.ts b/packages/agents-server/test/horton-pull-wake-e2e.test.ts
@@ -13,7 +13,7 @@ import {
   TEST_POSTGRES_URL,
   resetElectricAgentsTestBackend,
 } from './test-backend'
-import type { StreamFn } from '@mariozechner/pi-agent-core'
+import type { StreamFn } from '@earendil-works/pi-agent-core'
 
 function createMockStreamFn(responseText: string): StreamFn {
   return vi.fn(((model) => {

diff --git a/packages/agents/package.json b/packages/agents/package.json
@@ -54,15 +54,15 @@
     "@durable-streams/state": "https://pkg.pr.new/durable-streams/durable-streams/@durable-streams/state@5d5c217",
     "@electric-ax/agents-mcp": "workspace:*",
     "@electric-ax/agents-runtime": "workspace:*",
-    "@mariozechner/pi-agent-core": "^0.70.2",
-    "@mariozechner/pi-ai": "^0.70.2",
     "@sinclair/typebox": "^0.34.48",
     "better-sqlite3": "^12.9.0",
     "nanoid": "^3.3.11",
     "pino": "^10.3.1",
     "pino-pretty": "^13.0.0",
     "sqlite-vec": "^0.1.9",
-    "zod": "^4.3.6"
+    "zod": "^4.3.6",
+    "@earendil-works/pi-agent-core": "^0.75.4",
+    "@earendil-works/pi-ai": "^0.75.4"
   },
   "devDependencies": {
     "@types/better-sqlite3": "^7.6.13",

diff --git a/packages/agents/src/agents/horton.ts b/packages/agents/src/agents/horton.ts
@@ -13,7 +13,7 @@ import {
   type BuiltinAgentModelConfig,
   type BuiltinModelCatalog,
 } from '../model-catalog'
-import type { AgentTool, StreamFn } from '@mariozechner/pi-agent-core'
+import type { AgentTool, StreamFn } from '@earendil-works/pi-agent-core'
 import type {
   EntityRegistry,
   HandlerContext,

diff --git a/packages/agents/src/agents/worker.ts b/packages/agents/src/agents/worker.ts
@@ -16,7 +16,7 @@ import {
   type BuiltinModelCatalog,
 } from '../model-catalog'
 import type { WorkerToolName } from '../tools/spawn-worker'
-import type { AgentTool, StreamFn } from '@mariozechner/pi-agent-core'
+import type { AgentTool, StreamFn } from '@earendil-works/pi-agent-core'
 import type {
   EntityRegistry,
   HandlerContext,

diff --git a/packages/agents/src/bootstrap.ts b/packages/agents/src/bootstrap.ts
@@ -22,7 +22,7 @@ import type {
   RuntimeHandler,
 } from '@electric-ax/agents-runtime'
 import type { ChangeEvent } from '@durable-streams/state'
-import type { StreamFn } from '@mariozechner/pi-agent-core'
+import type { StreamFn } from '@earendil-works/pi-agent-core'
 import type { IncomingMessage, ServerResponse } from 'node:http'
 import type { SkillsRegistry } from '@electric-ax/agents-runtime'
 

diff --git a/packages/agents/src/model-catalog.ts b/packages/agents/src/model-catalog.ts
@@ -1,4 +1,4 @@
-import { getModels } from '@mariozechner/pi-ai'
+import { getModels } from '@earendil-works/pi-ai'
 import {
   detectAvailableProviders,
   readCodexAccessToken,

diff --git a/packages/agents/src/server.ts b/packages/agents/src/server.ts
@@ -31,7 +31,7 @@ import type {
   PullWakeRunnerConfig,
 } from '@electric-ax/agents-runtime'
 import type { ChangeEvent } from '@durable-streams/state'
-import type { StreamFn } from '@mariozechner/pi-agent-core'
+import type { StreamFn } from '@earendil-works/pi-agent-core'
 
 export interface BuiltinAgentsServerOptions {
   agentServerUrl: string

diff --git a/packages/agents/src/tools/spawn-worker.ts b/packages/agents/src/tools/spawn-worker.ts
@@ -2,7 +2,7 @@ import { Type } from '@sinclair/typebox'
 import { nanoid } from 'nanoid'
 import { serverLog } from '../log'
 import type { BuiltinAgentModelConfig } from '../model-catalog'
-import type { AgentTool } from '@mariozechner/pi-agent-core'
+import type { AgentTool } from '@earendil-works/pi-agent-core'
 import type { HandlerContext } from '@electric-ax/agents-runtime'
 
 export const WORKER_TOOL_NAMES = [