diff --git a/src/agent-attempt.ts b/src/agent-attempt.ts index d22c39d..2627e97 100644 --- a/src/agent-attempt.ts +++ b/src/agent-attempt.ts @@ -28,10 +28,11 @@ export function createInitialStreamedOutputState(): StreamedOutputState { export function createEvaluatedOutputHandler(args: { agentType: EvaluateStreamedOutputOptions['agentType']; provider: string; - evaluationOptions?: Omit; - onEvaluatedOutput?: ( - output: EvaluatedAgentOutput, - ) => Promise | void; + evaluationOptions?: Omit< + EvaluateStreamedOutputOptions, + 'agentType' | 'provider' + >; + onEvaluatedOutput?: (output: EvaluatedAgentOutput) => Promise | void; }): { handleOutput: (output: AgentOutput) => Promise; getState: () => StreamedOutputState; diff --git a/src/message-agent-executor.ts b/src/message-agent-executor.ts index 07bdd9d..caf23c0 100644 --- a/src/message-agent-executor.ts +++ b/src/message-agent-executor.ts @@ -3,9 +3,7 @@ import path from 'path'; import { getErrorMessage } from './utils.js'; -import { - getAgentOutputText, -} from './agent-output.js'; +import { getAgentOutputText } from './agent-output.js'; import { createEvaluatedOutputHandler } from './agent-attempt.js'; import { AgentOutput, @@ -493,7 +491,11 @@ export async function runAgentForGroup( ) { pairedExecutionSummary = output.error.slice(0, 500); } - if (evaluation.newTrigger && outputText && output.status === 'success') { + if ( + evaluation.newTrigger && + outputText && + output.status === 'success' + ) { log.warn( { reason: evaluation.newTrigger.reason, @@ -501,10 +503,7 @@ export async function runAgentForGroup( }, 'Detected Claude rotation trigger in successful output', ); - } else if ( - evaluation.newTrigger && - typeof output.error === 'string' - ) { + } else if (evaluation.newTrigger && typeof output.error === 'string') { log.warn( { reason: evaluation.newTrigger.reason, diff --git a/src/message-runtime-flow.ts b/src/message-runtime-flow.ts index b808fc4..4ab28fe 100644 --- a/src/message-runtime-flow.ts +++ b/src/message-runtime-flow.ts @@ -51,8 +51,12 @@ export function buildPendingPairedTurn(args: { timezone: string; task: PairedTask; rawMissedMessages: Array<{ seq?: number | null; timestamp?: string | null }>; - recentHumanMessages: Parameters[0]['recentHumanMessages']; - labeledRecentMessages: Parameters[0]['labeledRecentMessages']; + recentHumanMessages: Parameters< + typeof buildReviewerPendingPrompt + >[0]['recentHumanMessages']; + labeledRecentMessages: Parameters< + typeof buildArbiterPromptForTask + >[0]['labeledRecentMessages']; resolveChannel: (taskStatus?: string | null) => Channel | null; }): PendingPairedTurn { const { @@ -215,7 +219,8 @@ export function resolveBotOnlyPairedFollowUpAction(args: { return { kind: 'none' }; } - const cursor = pendingCursorSource?.seq ?? pendingCursorSource?.timestamp ?? null; + const cursor = + pendingCursorSource?.seq ?? pendingCursorSource?.timestamp ?? null; const lastTurnOutput = getPairedTurnOutputs(task.id).at(-1); const nextTurnAction = resolveNextTurnAction({ taskStatus: task.status, diff --git a/src/paired-execution-context-shared.ts b/src/paired-execution-context-shared.ts index 349e2c1..a2e7a2f 100644 --- a/src/paired-execution-context-shared.ts +++ b/src/paired-execution-context-shared.ts @@ -17,8 +17,7 @@ export function classifyVerdict(summary: string | null | undefined): Verdict { if (!cleaned) return 'continue'; const firstLine = cleaned.split('\n')[0].trim(); if (/^\*{0,2}BLOCKED\*{0,2}\b/i.test(firstLine)) return 'blocked'; - if (/^\*{0,2}NEEDS_CONTEXT\*{0,2}\b/i.test(firstLine)) - return 'needs_context'; + if (/^\*{0,2}NEEDS_CONTEXT\*{0,2}\b/i.test(firstLine)) return 'needs_context'; if (/^\*{0,2}DONE_WITH_CONCERNS\*{0,2}\b/i.test(firstLine)) return 'done_with_concerns'; if (/^\*{0,2}DONE\*{0,2}\b/i.test(firstLine)) return 'done';