test: drain heartbeat work before deleting recovery fixtures

Co-Authored-By: Paperclip <noreply@paperclip.ing>
This commit is contained in:
Devin FoleyandPaperclip committed 2026-10-04 00:22:36 -07:00
1 parent 99c84ccca2
commit 722db815da
1 file changed
+3 -1
@@ -548,7 +548,9 @@ describeEmbeddedPostgres("heartbeat orphaned process recovery", () => {
}
await new Promise((resolve) => setTimeout(resolve, 50));
await waitForHeartbeatIdle(db, 5_000);
await new Promise((resolve) => setTimeout(resolve, 100));
// Terminal rows do not mean their background finalizers have returned.
// Drain tracked wakeups too: one can still create a run after the row poll.
await heartbeatService(db).drainActiveRunExecutions();
await db.delete(activityLog);
await db.delete(agentRuntimeState);
await db.delete(companySkills);