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 () => {