Function runPiHistorian

packages/pi-plugin/src/pi-historian-runner.ts:241–1254

(deps: PiHistorianDeps)

}

export async function runPiHistorian(deps: PiHistorianDeps): Promise<void> {
	const {
		db,
		sessionId,
		directory,
		provider,
		runner,
		historianModel,
		fallbackModels,
		historianChunkTokens,
		boundarySnapshot: providedBoundarySnapshot,
		refreshBoundarySnapshot,
		currentContextLimit,
		historianTimeoutMs = DEFAULT_HISTORIAN_TIMEOUT_MS,
		twoPass,
		thinkingLevel,
		memoryEnabled,
		autoPromote,
		userMemoriesEnabled,
		onPublished,
		compartmentLeaseHolderId,
		readBranchEntries,
		notifyIssue,
		ensureProjectRegistered = ensureProjectRegisteredFromPiDirectory,
	} = deps;

	const notify = async (message: string): Promise<void> => {
		if (shouldSuppressHistorianAlert(sessionId)) {
			sessionLog(sessionId, "historian alert suppressed (cooldown)");
			return;
		}
		try {
			await notifyIssue?.(message);
		} catch (error) {
			sessionLog(sessionId, "historian notify failed", {
				error: describeError(error).brief,
			});
		}
	};

	updateSessionMeta(db, sessionId, { compartmentInProgress: true });

	// historian_runs telemetry (migration v24) — recorded ONCE in finally so every
	// exit path is logged. Best-effort. Mirrors the OpenCode incremental runner.
	const invocationBaseline = getLatestHistorianInvocationId(db, sessionId);
	const telemetry: Partial<HistorianRunInput> = {
		runKind: "incremental",
		status: "failed",
	};
	let completedSuccessfully = false;
	let retainDrainReservationForRetryThrottle = false;
	let drainReservation: ReturnType<
		typeof reserveProtectedTailDrainTokens
	>["reservation"] = null;
	const rollbackDrainReservation = (): void => {
		if (!drainReservation) return;
		rollbackProtectedTailDrainReservation(db, drainReservation);
		drainReservation = null;