fix(heartbeat): skip retries for promoted comment wakes

server/src/__tests__/heartbeat-comment-wake-batching.test.ts

@@ -262,7 +262,7 @@ describe("heartbeat comment wake batching", () => {
           payloadTemplate: {
             message: "wake now",
           },
-          waitTimeoutMs: 2_000,
+          waitTimeoutMs: 10_000,
         },
         runtimeConfig: {},
         permissions: {},
@@ -455,7 +455,7 @@ describe("heartbeat comment wake batching", () => {
           payloadTemplate: {
             message: "wake now",
           },
-          waitTimeoutMs: 2_000,
+          waitTimeoutMs: 10_000,
         },
         runtimeConfig: {},
         permissions: {},

server/src/services/heartbeat.ts

@@ -2062,6 +2062,9 @@ export function heartbeatService(db: Db) {
   ) {
     const contextSnapshot = parseObject(run.contextSnapshot);
     const issueId = readNonEmptyString(contextSnapshot.issueId);
+    const isPromotedDeferredCommentWake =
+      readNonEmptyString(contextSnapshot.wakeReason) === "issue_execution_promoted" &&
+      extractWakeCommentIds(contextSnapshot).length > 0;
     if (!issueId) {
       if (run.issueCommentStatus !== "not_applicable") {
         await patchRunIssueCommentStatus(run.id, {
@@ -2073,6 +2076,15 @@ export function heartbeatService(db: Db) {
       return { outcome: "not_applicable" as const, queuedRun: null };
     }
 
+    if (isPromotedDeferredCommentWake) {
+      await patchRunIssueCommentStatus(run.id, {
+        issueCommentStatus: "not_applicable",
+        issueCommentSatisfiedByCommentId: null,
+        issueCommentRetryQueuedAt: null,
+      });
+      return { outcome: "not_applicable" as const, queuedRun: null };
+    }
+
     const postedComment = await findRunIssueComment(run.id, run.companyId, issueId);
     if (postedComment) {
       await patchRunIssueCommentStatus(run.id, {