From 50217ad02afcf37575c1ca24a266e3006f6bfb03 Mon Sep 17 00:00:00 2001
From: Dotta <bippadotta@protonmail.com>
Date: Fri, 30 Oct 2026 16:42:27 -0500
Subject: [PATCH] test(heartbeat): use test-only signal setup and inspect saved
 stdout

Co-Authored-By: Paperclip <noreply@paperclip.ing>
---
 .../__tests__/heartbeat-run-dispatch-lifecycle.test.ts    | 8 ++++----
 server/src/__tests__/heartbeat-run-dispatch-work.test.ts  | 1 +
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/server/src/__tests__/heartbeat-run-dispatch-lifecycle.test.ts b/server/src/__tests__/heartbeat-run-dispatch-lifecycle.test.ts
index 09a5f8b7ec0..3d6566e543d 100644
--- a/server/src/__tests__/heartbeat-run-dispatch-lifecycle.test.ts
+++ b/server/src/__tests__/heartbeat-run-dispatch-lifecycle.test.ts
@@ -1,9 +1,9 @@
 import { PgDialect } from "drizzle-orm/pg-core";
 import { afterEach, describe, expect, it, vi } from "vitest";
-import { installDatabaseWorkSignals } from "@paperclipai/db";
-import { createDeliveryWorkCoordinator } from "../delivery-work-coordinator.js";
-import { notifyRunDispatch } from "../run-dispatch-notifications.js";
-import { registerRunDispatchWork } from "./dispatch-work.js";
+import { installDatabaseWorkSignals } from "../../../packages/db/src/work-signals.js";
+import { createDeliveryWorkCoordinator } from "../services/delivery-work-coordinator.js";
+import { notifyRunDispatch } from "../services/run-dispatch-notifications.js";
+import { registerRunDispatchWork } from "../services/heartbeat/dispatch-work.js";
 
 const cleanup: Array<() => Promise<void>> = [];
 afterEach(async () => {
diff --git a/server/src/__tests__/heartbeat-run-dispatch-work.test.ts b/server/src/__tests__/heartbeat-run-dispatch-work.test.ts
index 3d6f90aa71f..4a616887479 100644
--- a/server/src/__tests__/heartbeat-run-dispatch-work.test.ts
+++ b/server/src/__tests__/heartbeat-run-dispatch-work.test.ts
@@ -78,6 +78,7 @@ describe.skipIf(!support.supported)("run dispatch production wiring (controlled
   async function completed(id: string) {
     await vi.waitFor(async () => expect((await status(id))?.status).toBe("succeeded"), { timeout: 10_000 });
     await heartbeat.drainActiveRunExecutions();
+    expect((await status(id)).stdoutExcerpt).toContain("dispatch-proof");
   }
   it("keeps fresh empty, configured idle and retained terminal history quiet", async () => {
     await start(); await quiet();