nyrn
/
openclaw
mirror of https://github.com/openclaw/openclaw.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

perf(reply): lazy-load embedded queue steering

This commit is contained in:
Vincent Koc 2026-03-22 18:32:16 -07:00
parent bad9c8c223
commit 2db10fb1d4
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/agents/pi-embedded-queue.runtime.ts Normal file
View File

@ -0,0 +1 @@
export { queueEmbeddedPiMessage } from "./pi-embedded.js";

10
src/auto-reply/reply/agent-runner.ts
View File

@ -3,7 +3,6 @@ import { lookupContextTokens } from "../../agents/context.js";
import { DEFAULT_CONTEXT_TOKENS } from "../../agents/defaults.js";
import { resolveModelAuthMode } from "../../agents/model-auth.js";
import { isCliProvider } from "../../agents/model-selection.js";
import { queueEmbeddedPiMessage } from "../../agents/pi-embedded.js";
import { hasNonzeroUsage } from "../../agents/usage.js";
import {
resolveSessionFilePath,
@ -58,6 +57,14 @@ import { createTypingSignaler } from "./typing-mode.js";
import type { TypingController } from "./typing.js";
const BLOCK_REPLY_SEND_TIMEOUT_MS = 15_000;
let piEmbeddedQueueRuntimePromise: Promise<
typeof import("../../agents/pi-embedded-queue.runtime.js")
> | null = null;
function loadPiEmbeddedQueueRuntime() {
piEmbeddedQueueRuntimePromise ??= import("../../agents/pi-embedded-queue.runtime.js");
return piEmbeddedQueueRuntimePromise;
}
export async function runReplyAgent(params: {
commandBody: string;
@ -194,6 +201,7 @@ export async function runReplyAgent(params: {
};
if (shouldSteer && isStreaming) {
const { queueEmbeddedPiMessage } = await loadPiEmbeddedQueueRuntime();
const steered = queueEmbeddedPiMessage(followupRun.run.sessionId, followupRun.prompt);
if (steered && !shouldFollowup) {
await touchActiveSessionEntry();