From ebee3b3b15f03b957c85e2b29149ebdf3c144321 Mon Sep 17 00:00:00 2001 From: Dotta Date: Sun, 23 Aug 2026 21:02:51 +0000 Subject: [PATCH] test: await recovery escalation activity Co-Authored-By: Paperclip --- .../__tests__/heartbeat-process-recovery.test.ts | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/server/src/__tests__/heartbeat-process-recovery.test.ts b/server/src/__tests__/heartbeat-process-recovery.test.ts index 713901cb615..bf995940b3a 100644 --- a/server/src/__tests__/heartbeat-process-recovery.test.ts +++ b/server/src/__tests__/heartbeat-process-recovery.test.ts @@ -5687,11 +5687,14 @@ describeEmbeddedPostgres("heartbeat orphaned process recovery", () => { ); expect(recoveryComment).toBeTruthy(); - const activity = await db.select().from(activityLog).where(eq(activityLog.entityId, issueId)); - expect(activity.some((event) => - (event.details as Record | null)?.source === - "recovery.reconcile_execution_review_participant", - )).toBe(true); + const escalationActivity = await waitForValue(async () => { + const activity = await db.select().from(activityLog).where(eq(activityLog.entityId, issueId)); + return activity.find((event) => + (event.details as Record | null)?.source === + "recovery.reconcile_execution_review_participant", + ) ?? null; + }, 8_000); + expect(escalationActivity).toBeTruthy(); }); it("blocks failed execution-review recovery under the reviewer when the source assignee differs", async () => {