From 7d02d939e03d5ac4271570655a7a33265bde3a34 Mon Sep 17 00:00:00 2001 From: nrslib <38722970+nrslib@users.noreply.github.com> Date: Mon, 9 Feb 2026 13:08:41 +0900 Subject: [PATCH] =?UTF-8?q?=E4=B8=A6=E5=88=97=E5=AE=9F=E8=A1=8C=E6=99=82?= =?UTF-8?q?=E3=81=AE=E3=82=BF=E3=82=B9=E3=82=AF=E5=AE=9F=E8=A1=8C=E6=99=82?= =?UTF-8?q?=E9=96=93=E4=B8=8A=E9=99=90=E6=92=A4=E5=BB=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/features/tasks/execute/pieceExecution.ts | 2 +- src/features/tasks/execute/taskExecution.ts | 22 +------------------- 2 files changed, 2 insertions(+), 22 deletions(-) diff --git a/src/features/tasks/execute/pieceExecution.ts b/src/features/tasks/execute/pieceExecution.ts index b543f62..b0defab 100644 --- a/src/features/tasks/execute/pieceExecution.ts +++ b/src/features/tasks/execute/pieceExecution.ts @@ -309,7 +309,7 @@ export async function executePiece( const additionalIterations = Number.parseInt(input, 10); if (Number.isInteger(additionalIterations) && additionalIterations > 0) { - pieceConfig.maxIterations += additionalIterations; + pieceConfig.maxIterations = request.maxIterations + additionalIterations; return additionalIterations; } diff --git a/src/features/tasks/execute/taskExecution.ts b/src/features/tasks/execute/taskExecution.ts index fc412d5..219711c 100644 --- a/src/features/tasks/execute/taskExecution.ts +++ b/src/features/tasks/execute/taskExecution.ts @@ -23,7 +23,6 @@ import { resolveTaskExecution } from './resolveTask.js'; export type { TaskExecutionOptions, ExecuteTaskOptions }; const log = createLogger('task'); -const TASK_TIMEOUT_MS = 60 * 60 * 1000; /** * Resolve a GitHub issue from task data's issue number. @@ -110,9 +109,7 @@ export async function executeAndCompleteTask( const executionLog: string[] = []; const taskAbortController = new AbortController(); const externalAbortSignal = parallelOptions?.abortSignal; - const taskTimeoutMs = externalAbortSignal ? TASK_TIMEOUT_MS : undefined; const taskAbortSignal = externalAbortSignal ? taskAbortController.signal : undefined; - let timeoutId: ReturnType | undefined; const onExternalAbort = (): void => { taskAbortController.abort(); @@ -143,21 +140,7 @@ export async function executeAndCompleteTask( taskColorIndex: parallelOptions?.taskColorIndex, }); - const timeoutPromise = taskTimeoutMs && taskTimeoutMs > 0 - ? new Promise((_, reject) => { - timeoutId = setTimeout(() => { - taskAbortController.abort(); - reject(new Error(`Task timed out after ${Math.floor(taskTimeoutMs / 60000)} minutes`)); - }, taskTimeoutMs); - }) - : undefined; - - const taskSuccess = timeoutPromise - ? await Promise.race([ - taskRunPromise, - timeoutPromise, - ]) - : await taskRunPromise; + const taskSuccess = await taskRunPromise; const completedAt = new Date().toISOString(); if (taskSuccess && isWorktree) { @@ -227,9 +210,6 @@ export async function executeAndCompleteTask( error(`Task "${task.name}" error: ${getErrorMessage(err)}`); return false; } finally { - if (timeoutId !== undefined) { - clearTimeout(timeoutId); - } if (externalAbortSignal) { externalAbortSignal.removeEventListener('abort', onExternalAbort); }