fix(pi-embedded-runner): propagate trigger-derived priority to the gl… · openclaw/openclaw@0580f57
coreindustri
·
2026-05-25
·
via Recent Commits to openclaw:main
File tree
src/agents/pi-embedded-runner
| Original file line number | Diff line number | Diff line change |
|---|
@@ -433,10 +433,15 @@ export async function runEmbeddedPiAgent(
|
433 | 433 | }, |
434 | 434 | laneTaskTimeoutMs, |
435 | 435 | ); |
436 | | -const enqueueGlobal = <T>(task: () => Promise<T>, opts?: CommandQueueEnqueueOptions) => |
437 | | -params.enqueue |
438 | | - ? params.enqueue(task, withLaneTimeout(opts)) |
439 | | - : enqueueCommandInLane(globalLane, task, withLaneTimeout(opts)); |
| 436 | +const enqueueGlobal = <T>(task: () => Promise<T>, opts?: CommandQueueEnqueueOptions) => { |
| 437 | +const globalOpts: CommandQueueEnqueueOptions = { |
| 438 | + ...opts, |
| 439 | +priority: sessionQueuePriority, |
| 440 | +}; |
| 441 | +return params.enqueue |
| 442 | + ? params.enqueue(task, withLaneTimeout(globalOpts)) |
| 443 | + : enqueueCommandInLane(globalLane, task, withLaneTimeout(globalOpts)); |
| 444 | +}; |
440 | 445 | const enqueueSession = <T>(task: () => Promise<T>, opts?: CommandQueueEnqueueOptions) => { |
441 | 446 | const sessionOpts: CommandQueueEnqueueOptions = { ...opts, priority: sessionQueuePriority }; |
442 | 447 | return params.enqueue |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。
