Jannik/PaperClipAI
1
0 Fork 0
mirror of https://github.com/paperclipai/paperclip.git synced 2026-11-02 16:58:52 +01:00
Code Issues Packages Projects Releases Wiki Activity

Bound recovery qualification database pools

Browse Source 
Co-Authored-By: Paperclip <noreply@paperclip.ing>
This commit is contained in:
DottaandPaperclip committed 2026-10-30 22:11:12 -05:00
1 parent 4888457d1f
commit cba8918f21
4 files changed
+5 -5
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

server/src/__tests__/native-cancellation-request.integration.test.ts
+1 -1
View File
@@ -14,7 +14,7 @@ describe("atomic caller cancellation request ownership", () => {
({ cancelNativeSession } = await import("../services/native-runtime/native-session-executor.js"));
const external = resolveExternalTestDatabaseUrl("PAPERCLIP_NATIVE_CANCELLATION_TEST_DATABASE_URL");
if (!external) database = await startEmbeddedPostgresTestDatabase("caller-stop-");
db = createDb(external ?? database!.connectionString);
db = createDb(external ?? database!.connectionString, { maxConnections: 6 });
}, 90_000);
afterAll(async () => { await db?.$client.end({ timeout: 1 }); await database?.cleanup(); });
async function fixture() {
server/src/__tests__/native-settled-process-release.test.ts
+1 -1
View File
@@ -66,7 +66,7 @@ suite("settled native run process identity", () => {
beforeAll(async () => {
if (!external) temporary = await startEmbeddedPostgresTestDatabase("native-settled-process-");
db = createDb(external ?? temporary!.connectionString);
db = createDb(external ?? temporary!.connectionString, { maxConnections: 6 });
if (external) await db.execute(sql`truncate companies cascade`);
companyId = randomUUID();
agentId = randomUUID();
server/src/services/heartbeat/agent-status.test.ts
+1 -1
View File
@@ -24,7 +24,7 @@ describePostgres("heartbeat agent status", () => {
beforeAll(async () => {
if (!external) database = await startEmbeddedPostgresTestDatabase("paperclip-agent-status-");
db = createDb(external ?? database!.connectionString);
db = createDb(external ?? database!.connectionString, { maxConnections: 6 });
if (external) {
db.$client.options.onnotice = () => {};
await db.execute(sql`truncate companies cascade`);
server/src/services/legacy-controller-lease.test.ts
+2 -2
View File
@@ -25,7 +25,7 @@ const support = external ? { supported: true } : await getEmbeddedPostgresTestSu
let db: ReturnType<typeof createDb>;
beforeAll(async () => {
if (!external) database = await startEmbeddedPostgresTestDatabase("legacy-controller-");
db = createDb(external ?? database.connectionString);
db = createDb(external ?? database.connectionString, { maxConnections: 6 });
}, 30000);
afterAll(async () => { await closeLivenessDb(db, 1); await db?.$client.end({ timeout: 1 }); await database?.cleanup(); });
async function seed() {
@@ -178,7 +178,7 @@ const support = external ? { supported: true } : await getEmbeddedPostgresTestSu
it("renews on one private pool per client that shutdown can end", async () => {
const run = await seed();
const owner = createDb(external ?? database.connectionString);
const owner = createDb(external ?? database.connectionString, { maxConnections: 6 });
const pool = livenessDb(owner);
expect(pool).not.toBe(owner);
expect(livenessDb(owner)).toBe(pool);