Function withRetry

packages/plugin/scripts/longmemeval/runner.ts:278–306

(
    config: RunnerConfig,
    operationName: string,
    run: (attempt: number, signal: AbortSignal) => Promise<T>,
)

}

async function withRetry<T>(
    config: RunnerConfig,
    operationName: string,
    run: (attempt: number, signal: AbortSignal) => Promise<T>,
): Promise<T> {
    let lastError: Error | null = null;

    for (let attempt = 1; attempt <= config.maxRequestAttempts; attempt += 1) {
        const controller = new AbortController();
        const timeout = setTimeout(() => controller.abort(), config.openCodeRequestTimeoutMs);
        try {
            return await run(attempt, controller.signal);
        } catch (error) {
            lastError = asError(error);
            clearTimeout(timeout);
            if (attempt >= config.maxRequestAttempts) break;
            const retryDelay = config.retryBaseDelayMs * 2 ** (attempt - 1);
            logLine(
                `${operationName} failed on attempt ${attempt}/${config.maxRequestAttempts}: ${lastError.message}; retrying in ${retryDelay}ms`,
            );
            await sleep(retryDelay);

        } finally {
            clearTimeout(timeout);
        }
    }

    throw lastError ?? new Error(`${operationName} failed`);
}

async function createSession(
    client: OpencodeClient,