RomanNum3ral
/
paperclip
mirror of https://github.com/paperclipai/paperclip.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: isolate workspace eligibility fixtures from clock precision 

Co-Authored-By: Paperclip <noreply@paperclip.ing>
This commit is contained in:
Dotta 2026-09-09 05:19:03 -05:00
parent cb381c6a5f
commit a72fd32191
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/__tests__/execution-workspaces-service.test.ts
View File

@ -1821,6 +1821,19 @@ describeEmbeddedPostgres("executionWorkspaceService.getCloseReadiness", () => {
const openDescendant = await seedTerminalWorkspace({ mergedPr: true, childStatus: "todo" });
const undelivered = await seedTerminalWorkspace();
// Test delivery eligibility independently of the sweep's clock boundary.
// Postgres timestamps retain sub-millisecond precision, so a just-inserted
// row can fall after the JavaScript boundary within the same millisecond.
await db
.update(executionWorkspaces)
.set({ updatedAt: new Date("2020-01-01T00:00:00Z") })
.where(inArray(executionWorkspaces.id, [
eligible.executionWorkspaceId,
activeRun.executionWorkspaceId,
openDescendant.executionWorkspaceId,
undelivered.executionWorkspaceId,
]));
const result = await svc.sweepTerminalWorkspaces();
const rows = await db
.select({ id: executionWorkspaces.id, status: executionWorkspaces.status, cleanupEligibleAt: executionWorkspaces.cleanupEligibleAt, cleanupReason: executionWorkspaces.cleanupReason })
@ -1833,7 +1846,7 @@ describeEmbeddedPostgres("executionWorkspaceService.getCloseReadiness", () => {
]));
const byId = new Map(rows.map((row) => [row.id, row]));
expect(result).toMatchObject({ archived: 1, skippedActiveRun: 1, skippedNonTerminalTree: 1, skippedUndelivered: 1 });
expect(result).toMatchObject({ checked: 4, archived: 1, skippedActiveRun: 1, skippedNonTerminalTree: 1, skippedUndelivered: 1 });
expect(byId.get(eligible.executionWorkspaceId)).toMatchObject({ status: "archived", cleanupReason: "issue_terminal" });
expect(byId.get(eligible.executionWorkspaceId)?.cleanupEligibleAt).toBeInstanceOf(Date);
expect(byId.get(activeRun.executionWorkspaceId)?.status).toBe("active");