fix: dynamic cli log subsystem
This commit is contained in:
parent
540d06068a
commit
d29ae750a7
@ -30,7 +30,17 @@ import { FailoverError, resolveFailoverStatus } from "./failover-error.js";
|
|||||||
import { classifyFailoverReason, isFailoverErrorMessage } from "./pi-embedded-helpers.js";
|
import { classifyFailoverReason, isFailoverErrorMessage } from "./pi-embedded-helpers.js";
|
||||||
import type { EmbeddedPiRunResult } from "./pi-embedded-runner.js";
|
import type { EmbeddedPiRunResult } from "./pi-embedded-runner.js";
|
||||||
|
|
||||||
const log = createSubsystemLogger("agent/claude-cli");
|
/** Cache of per-provider loggers to avoid creating new ones on each call. */
|
||||||
|
const providerLoggers = new Map<string, ReturnType<typeof createSubsystemLogger>>();
|
||||||
|
|
||||||
|
function getProviderLogger(provider: string) {
|
||||||
|
let logger = providerLoggers.get(provider);
|
||||||
|
if (!logger) {
|
||||||
|
logger = createSubsystemLogger(`agent/${provider}`);
|
||||||
|
providerLoggers.set(provider, logger);
|
||||||
|
}
|
||||||
|
return logger;
|
||||||
|
}
|
||||||
|
|
||||||
export async function runCliAgent(params: {
|
export async function runCliAgent(params: {
|
||||||
sessionId: string;
|
sessionId: string;
|
||||||
@ -51,6 +61,7 @@ export async function runCliAgent(params: {
|
|||||||
images?: ImageContent[];
|
images?: ImageContent[];
|
||||||
}): Promise<EmbeddedPiRunResult> {
|
}): Promise<EmbeddedPiRunResult> {
|
||||||
const started = Date.now();
|
const started = Date.now();
|
||||||
|
const log = getProviderLogger(params.provider);
|
||||||
const resolvedWorkspace = resolveUserPath(params.workspaceDir);
|
const resolvedWorkspace = resolveUserPath(params.workspaceDir);
|
||||||
const workspaceDir = resolvedWorkspace;
|
const workspaceDir = resolvedWorkspace;
|
||||||
|
|
||||||
@ -76,7 +87,10 @@ export async function runCliAgent(params: {
|
|||||||
config: params.config,
|
config: params.config,
|
||||||
sessionKey: params.sessionKey,
|
sessionKey: params.sessionKey,
|
||||||
sessionId: params.sessionId,
|
sessionId: params.sessionId,
|
||||||
warn: makeBootstrapWarn({ sessionLabel, warn: (message) => log.warn(message) }),
|
warn: makeBootstrapWarn({
|
||||||
|
sessionLabel,
|
||||||
|
warn: (message) => log.warn(message),
|
||||||
|
}),
|
||||||
});
|
});
|
||||||
const { defaultAgentId, sessionAgentId } = resolveSessionAgentIds({
|
const { defaultAgentId, sessionAgentId } = resolveSessionAgentIds({
|
||||||
sessionKey: params.sessionKey,
|
sessionKey: params.sessionKey,
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user