style: format task scheduler
This commit is contained in:
@@ -327,11 +327,15 @@ async function runTask(
|
|||||||
if (streamedOutput.phase === 'progress') {
|
if (streamedOutput.phase === 'progress') {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
const evaluation = evaluateStreamedOutput(streamedOutput, streamedState, {
|
const evaluation = evaluateStreamedOutput(
|
||||||
agentType: isClaudeAgent ? 'claude' : 'codex',
|
streamedOutput,
|
||||||
provider,
|
streamedState,
|
||||||
shortCircuitTriggeredErrors: true,
|
{
|
||||||
});
|
agentType: isClaudeAgent ? 'claude' : 'codex',
|
||||||
|
provider,
|
||||||
|
shortCircuitTriggeredErrors: true,
|
||||||
|
},
|
||||||
|
);
|
||||||
streamedState = evaluation.state;
|
streamedState = evaluation.state;
|
||||||
|
|
||||||
if (
|
if (
|
||||||
@@ -535,7 +539,9 @@ async function runTask(
|
|||||||
if (retryTrigger.shouldRotate) {
|
if (retryTrigger.shouldRotate) {
|
||||||
trigger = { reason: retryTrigger.reason };
|
trigger = { reason: retryTrigger.reason };
|
||||||
lastRotationMessage =
|
lastRotationMessage =
|
||||||
retryAttempt.attemptError || retryAttempt.output.error || undefined;
|
retryAttempt.attemptError ||
|
||||||
|
retryAttempt.output.error ||
|
||||||
|
undefined;
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
|
|||||||
Reference in New Issue
Block a user