mirror of
https://github.com/openclaw/openclaw.git
synced 2026-02-19 18:39:20 -05:00
fix: stabilize embedded runner queueing
This commit is contained in:
@@ -31,6 +31,8 @@ Docs: https://docs.clawd.bot
|
|||||||
- CLI: explain when auth profiles are excluded by auth.order in probe details.
|
- CLI: explain when auth profiles are excluded by auth.order in probe details.
|
||||||
- CLI: drop the em dash when the banner tagline wraps to a second line.
|
- CLI: drop the em dash when the banner tagline wraps to a second line.
|
||||||
- CLI: inline auth probe errors in status rows to reduce wrapping.
|
- CLI: inline auth probe errors in status rows to reduce wrapping.
|
||||||
|
- Agents: honor enqueue overrides for embedded runs to avoid queue deadlocks in tests.
|
||||||
|
- Daemon: use platform PATH delimiters when building minimal service paths.
|
||||||
- Linux: include env-configured user bin roots in systemd PATH and align PATH audits. (#1512) Thanks @robbyczgw-cla.
|
- Linux: include env-configured user bin roots in systemd PATH and align PATH audits. (#1512) Thanks @robbyczgw-cla.
|
||||||
- TUI: render Gateway slash-command replies as system output (for example, `/context`).
|
- TUI: render Gateway slash-command replies as system output (for example, `/context`).
|
||||||
- Media: preserve PNG alpha when possible; fall back to JPEG when still over size cap. (#1491) Thanks @robbyczgw-cla.
|
- Media: preserve PNG alpha when possible; fall back to JPEG when still over size cap. (#1491) Thanks @robbyczgw-cla.
|
||||||
|
|||||||
@@ -71,6 +71,8 @@ export async function runEmbeddedPiAgent(
|
|||||||
const globalLane = resolveGlobalLane(params.lane);
|
const globalLane = resolveGlobalLane(params.lane);
|
||||||
const enqueueGlobal =
|
const enqueueGlobal =
|
||||||
params.enqueue ?? ((task, opts) => enqueueCommandInLane(globalLane, task, opts));
|
params.enqueue ?? ((task, opts) => enqueueCommandInLane(globalLane, task, opts));
|
||||||
|
const enqueueSession =
|
||||||
|
params.enqueue ?? ((task, opts) => enqueueCommandInLane(sessionLane, task, opts));
|
||||||
const channelHint = params.messageChannel ?? params.messageProvider;
|
const channelHint = params.messageChannel ?? params.messageProvider;
|
||||||
const resolvedToolResultFormat =
|
const resolvedToolResultFormat =
|
||||||
params.toolResultFormat ??
|
params.toolResultFormat ??
|
||||||
@@ -81,7 +83,7 @@ export async function runEmbeddedPiAgent(
|
|||||||
: "markdown");
|
: "markdown");
|
||||||
const isProbeSession = params.sessionId?.startsWith("probe-") ?? false;
|
const isProbeSession = params.sessionId?.startsWith("probe-") ?? false;
|
||||||
|
|
||||||
return enqueueCommandInLane(sessionLane, () =>
|
return enqueueSession(() =>
|
||||||
enqueueGlobal(async () => {
|
enqueueGlobal(async () => {
|
||||||
const started = Date.now();
|
const started = Date.now();
|
||||||
const resolvedWorkspace = resolveUserPath(params.workspaceDir);
|
const resolvedWorkspace = resolveUserPath(params.workspaceDir);
|
||||||
|
|||||||
@@ -121,7 +121,8 @@ export function buildMinimalServicePath(options: BuildServicePathOptions = {}):
|
|||||||
return env.PATH ?? "";
|
return env.PATH ?? "";
|
||||||
}
|
}
|
||||||
|
|
||||||
return getMinimalServicePathPartsFromEnv({ ...options, env }).join(path.delimiter);
|
const delimiter = platform === "win32" ? path.win32.delimiter : path.posix.delimiter;
|
||||||
|
return getMinimalServicePathPartsFromEnv({ ...options, env }).join(delimiter);
|
||||||
}
|
}
|
||||||
|
|
||||||
export function buildServiceEnvironment(params: {
|
export function buildServiceEnvironment(params: {
|
||||||
|
|||||||
Reference in New Issue
Block a user