diff --git a/server/src/__tests__/task-watchdogs-scheduler.test.ts b/server/src/__tests__/task-watchdogs-scheduler.test.ts index fdc8c26eb68..f0c8a093526 100644 --- a/server/src/__tests__/task-watchdogs-scheduler.test.ts +++ b/server/src/__tests__/task-watchdogs-scheduler.test.ts @@ -421,6 +421,8 @@ describeEmbeddedPostgres("task watchdog scheduler", () => { .from(issueWatchdogProofOutcomes) .where(eq(issueWatchdogProofOutcomes.watchdogId, watchdog!.id)); expect(outcomes).toHaveLength(1); + expect(outcomes[0]?.resultClassification).toBe("stopped"); + expect(outcomes[0]?.redactedDetails).toEqual(expect.objectContaining({ classification: "stopped" })); await db .update(issues) diff --git a/server/src/services/task-watchdogs.ts b/server/src/services/task-watchdogs.ts index 815c6b445ac..21ae5ff0120 100644 --- a/server/src/services/task-watchdogs.ts +++ b/server/src/services/task-watchdogs.ts @@ -1381,6 +1381,7 @@ export function taskWatchdogService(db: Db, deps: TaskWatchdogServiceDeps = {}) if (!outcome) return { watchdog, outcome: null, suppressesCurrentProof: false }; const method = `watchdog_issue_status:${watchdogIssue.status}`; + const resultClassification = classification.state === "already_reviewed" ? "stopped" : classification.state; await recordWatchdogProofOutcome({ watchdog, watchdogIssue, @@ -1388,7 +1389,7 @@ export function taskWatchdogService(db: Db, deps: TaskWatchdogServiceDeps = {}) method, stopFingerprint, proofObligationFingerprint, - resultClassification: classification.state, + resultClassification, redactedDetails: { version: 1, target: { @@ -1396,7 +1397,7 @@ export function taskWatchdogService(db: Db, deps: TaskWatchdogServiceDeps = {}) watchdogIssueId: watchdogIssue.id, }, method, - classification: classification.state, + classification: resultClassification, watchdogIssueStatus: watchdogIssue.status, hasUnresolvedBlocker, hasPendingReviewPath,