mirror of
https://github.com/paperclipai/paperclip.git
synced 2026-11-05 12:29:37 +01:00
Merge reviewed inventory fixture qualification into history follow-up
Co-Authored-By: Paperclip <noreply@paperclip.ing> * commit '5be6fc35022cfbbb0bcfbcfdee78802f953b02d3': test(server): complete nested assignment work before quiet proof
This commit is contained in:
commit
021833a602
1 file changed
+5
-1
@@ -14,7 +14,9 @@ describeIssueRecovery("issue recovery production producers and assignments", ()
|
||||
await finish(issue.id); await quiet();
|
||||
}, 90_000);
|
||||
it("fences nested assignment writes until outer commit and ignores rollback", async () => {
|
||||
const f = await fixture(); await start(); await quiet();
|
||||
const f = await fixture();
|
||||
const providerFailures = await state.completingProvider(f);
|
||||
await start(); await quiet();
|
||||
let committedId = "";
|
||||
await state.db.transaction(async outer => {
|
||||
await outer.transaction(async nested => {
|
||||
@@ -33,6 +35,8 @@ describeIssueRecovery("issue recovery production producers and assignments", ()
|
||||
})).rejects.toThrow("rollback control");
|
||||
await quiet();
|
||||
expect(await state.db.select().from(issues).where(eq(issues.title, "Nested rollback"))).toHaveLength(0);
|
||||
expect(providerFailures).toEqual([]);
|
||||
expect(await state.db.select().from(heartbeatRuns)).toHaveLength(1);
|
||||
}, 90_000);
|
||||
it("retains the first committed assignment during drain and executes on resume", async () => {
|
||||
const f = await fixture(); await start(); await quiet(); state.draining = true;
|
||||
|
||||
Reference in new issue
Block a user