diff --git a/server/src/__tests__/heartbeat-dependency-scheduling.test.ts b/server/src/__tests__/heartbeat-dependency-scheduling.test.ts index 7748bfb35bb..f2560bcdd5e 100644 --- a/server/src/__tests__/heartbeat-dependency-scheduling.test.ts +++ b/server/src/__tests__/heartbeat-dependency-scheduling.test.ts @@ -11,6 +11,8 @@ import { createDb, documentRevisions, documents, + environmentLeases, + environments, heartbeatRunEvents, heartbeatRuns, issueComments, @@ -122,6 +124,7 @@ describeEmbeddedPostgres("heartbeat dependency-aware queued run selection", () = await new Promise((resolve) => setTimeout(resolve, 50)); } await new Promise((resolve) => setTimeout(resolve, 50)); + await db.delete(environmentLeases); await db.delete(activityLog); await db.delete(companySkills); await db.delete(issueComments); @@ -137,6 +140,8 @@ describeEmbeddedPostgres("heartbeat dependency-aware queued run selection", () = await db.delete(agentWakeupRequests); await db.delete(agentRuntimeState); await db.delete(agents); + await db.delete(companySkills); + await db.delete(environments); await db.delete(companies); }); @@ -511,6 +516,16 @@ describeEmbeddedPostgres("heartbeat dependency-aware queued run selection", () = finishFirstRun(); + const firstRunSucceeded = await waitForCondition(async () => { + const run = await db + .select({ status: heartbeatRuns.status }) + .from(heartbeatRuns) + .where(eq(heartbeatRuns.id, firstWake!.id)) + .then((rows) => rows[0] ?? null); + return run?.status === "succeeded"; + }); + expect(firstRunSucceeded).toBe(true); + const secondRunSucceeded = await waitForCondition(async () => { const run = await db .select({ status: heartbeatRuns.status })