Skip to content

Commit aebc3fe

Browse files
Clean up AgentPond dev PR metadata
1 parent 1052aa2 commit aebc3fe

9 files changed

Lines changed: 22 additions & 19 deletions

File tree

.changeset/direct-duckdb-dev.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,4 +2,4 @@
22
"agentpond": minor
33
---
44

5-
Write `agentpond dev` ingestion directly to the dev DuckDB cache and make dev sync a no-op while blocking competing dev writes.
5+
Add a local `agentpond dev` ingestion server that writes directly to the dev DuckDB cache, makes dev sync a no-op, and blocks competing dev writes.

.changeset/warm-ponds-dev.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,4 +2,4 @@
22
"agentpond": minor
33
---
44

5-
Add named environments with per-environment DuckDB caches using `agentpond env` and a local `agentpond dev` ingestion server. .
5+
Add named environments with per-environment DuckDB caches using `agentpond env`.

apps/cli/src/commands/environment.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { existsSync } from "node:fs";
22
import { join, resolve } from "node:path";
33
import {
4-
configFromEnv,
4+
type configFromEnv,
55
DEV_SERVER_RUNNING_MESSAGE,
66
initAgentPondEnvironment,
77
isDevServerRunning,

apps/cli/src/commands/scores.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
import { randomUUID } from "node:crypto";
22
import {
3-
configFromEnv,
3+
type configFromEnv,
44
eventTypes,
55
type IngestionEvent,
66
} from "@agentpond/core";
77
import {
8-
AgentPondCache,
8+
type AgentPondCache,
99
DuckDbIngestionSink,
1010
ensureDuckDbSchema,
1111
} from "@agentpond/duckdb";
@@ -17,14 +17,14 @@ import {
1717
requiredFlag,
1818
stringFlag,
1919
} from "../cli-support.js";
20+
import { objectStoreForConfig } from "../object-store.js";
21+
import { sql } from "../sql.js";
22+
import { writeEventsAndSyncCache } from "../sync-write.js";
2023
import {
2124
assertDevServerNotRunning,
2225
cacheForRead,
2326
isDevEnvironment,
2427
} from "./environment.js";
25-
import { objectStoreForConfig } from "../object-store.js";
26-
import { sql } from "../sql.js";
27-
import { writeEventsAndSyncCache } from "../sync-write.js";
2828

2929
export async function handleScoreCommand(
3030
action: string | undefined,

apps/cli/src/commands/traces.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { randomBytes } from "node:crypto";
2-
import { configFromEnv } from "@agentpond/core";
2+
import type { configFromEnv } from "@agentpond/core";
33
import {
4-
AgentPondCache,
4+
type AgentPondCache,
55
DuckDbIngestionSink,
66
ensureDuckDbSchema,
77
} from "@agentpond/duckdb";
@@ -12,15 +12,15 @@ import {
1212
print,
1313
stringFlag,
1414
} from "../cli-support.js";
15+
import { objectStoreForConfig } from "../object-store.js";
16+
import { manualTraceResourceSpans } from "../otel-trace.js";
17+
import { sql } from "../sql.js";
18+
import { writeOtelAndSyncCache } from "../sync-write.js";
1519
import {
1620
assertDevServerNotRunning,
1721
cacheForRead,
1822
isDevEnvironment,
1923
} from "./environment.js";
20-
import { objectStoreForConfig } from "../object-store.js";
21-
import { manualTraceResourceSpans } from "../otel-trace.js";
22-
import { sql } from "../sql.js";
23-
import { writeOtelAndSyncCache } from "../sync-write.js";
2424

2525
export async function handleTraceCommand(
2626
action: string | undefined,

packages/duckdb/src/cache/index.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ import { DuckDbDirectIngestion } from "../ingestion/direct-ingestion.js";
22
import { type DuckDbAccessMode, DuckDbOperations } from "./db-operations.js";
33
import { DuckDbStoreSync } from "./store-sync.js";
44
import type { SyncFromStoreParams, SyncResult } from "./sync-types.js";
5+
56
export type {
67
SyncFromStoreParams,
78
SyncProgress,

packages/duckdb/src/cache/store-sync.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@ import {
55
} from "@agentpond/core";
66
import type { DuckDbOperations } from "./db-operations.js";
77
import { BatchProjection, rawEventRow, stringValue } from "./projection.js";
8+
import type { SyncStateStore } from "./sync-state.js";
9+
import { createSyncStateStore } from "./sync-state.js";
810
import type {
911
SyncFromStoreParams,
1012
SyncProgress,
1113
SyncResult,
1214
} from "./sync-types.js";
13-
import type { SyncStateStore } from "./sync-state.js";
14-
import { createSyncStateStore } from "./sync-state.js";
1515

1616
type PendingObject = {
1717
manifestKey: string | null;

packages/duckdb/src/ingestion/sink.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,9 @@
11
import type { IngestionEvent } from "@agentpond/core";
22
import { AgentPondCache } from "../cache/index.js";
3-
import type { DuckDbDirectIngestion } from "./direct-ingestion.js";
4-
import type { DirectWriteResult } from "./direct-ingestion.js";
3+
import type {
4+
DirectWriteResult,
5+
DuckDbDirectIngestion,
6+
} from "./direct-ingestion.js";
57

68
export class DuckDbIngestionSink {
79
constructor(private readonly dbPath: string) {}

tests/cli.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ import { tmpdir } from "node:os";
44
import { join } from "node:path";
55
import test from "node:test";
66
import {
7-
acquireDevServerLock,
87
type AgentPondConfig,
8+
acquireDevServerLock,
99
eventTypes,
1010
type IngestionEvent,
1111
initAgentPondEnvironment,

0 commit comments

Comments
 (0)