Method runOnce

packages/pi-plugin/src/subagent-runner.ts:414–1055

(
		options: SubagentRunOptions,
	)

	}

	private async runOnce(
		options: SubagentRunOptions,
	): Promise<SubagentRunResult> {
		const startTime = Date.now();
		let recordedAccounting = false;
		const recordAccounting = (
			result: SubagentRunResult,
			messages: unknown[] = [],
		) => {
			if (!options.accountingSessionId || recordedAccounting) return;
			recordedAccounting = true;
			recordChildInvocation({
				db: openDatabase(),
				parentSessionId: options.accountingSessionId,
				harness: "pi",
				subagent:
					options.accountingSubagent ?? inferAccountingSubagent(options.agent),
				task: options.accountingTask ?? null,
				startedAt: startTime,
				status: result.ok
					? "completed"
					: result.reason === "abort"
						? "aborted"
						: "failed",
				messages,
				providerId:
					typeof options.model === "string"
						? options.model.split("/")[0]
						: null,
				modelId:
					typeof options.model === "string"
						? options.model.split("/").slice(1).join("/")
						: null,
				error: result.ok ? null : result.error,
				parentInvocationId: options.accountingParentInvocationId ?? null,
			});
		};
		if (options.signal?.aborted) {
			const result: SubagentRunResult = {
				ok: false,
				reason: "abort",
				error: "pi subagent aborted by caller",
				durationMs: Date.now() - startTime,
			};
			// Same best-effort contract as settle(): accounting must never throw
			// out of the return path (a DB write failure here would propagate to
			// the caller as a spurious spawn error). Telemetry is best-effort.
			try {
				recordAccounting(result);
			} catch (err) {
				sessionLog(
					options.accountingSessionId ?? "subagent",
					`subagent accounting failed (continuing): ${err instanceof Error ? err.message : String(err)}`,
				);
			}
			return result;
		}
		const failBeforeSpawn = (