fix(agents): skip dormant completion wake probes · opencl...

Recent Commits to openclaw:main

galiniliev · 2026-05-19 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@ Docs: https://docs.openclaw.ai`
`6`	`6`
`7`	`7`	`### Fixes`
`8`	`8`
	`9`	+- Agents/subagents: skip stale embedded-run wake probes for dormant completion requesters, so late subagent completions go straight to requester-agent/direct handoff instead of producing `reason=no_active_run` queue noise. (#82964) Thanks @galiniliev.
`9`	`10`	`- WhatsApp: drain pending outbound deliveries on a 30s periodic timer in addition to the reconnect handler, so messages enqueued while the provider is already connected no longer wait for the next reconnect to send. (#79083) Thanks @Oviemudiaga.`
`10`	`11`
`11`	`12`	`## 2026.5.19`

Original file line number	Diff line number	Diff line change
`@@ -849,12 +849,14 @@ describe("deliverSubagentAnnouncement completion delivery", () => {`
`849`	`849`
`850`	`850`	`it("keeps direct external delivery for dormant completion requesters", async () => {`
`851`	`851`	`const callGateway = createGatewayMock();`
	`852`	`+const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(false);`
`852`	`853`	`await deliverSlackThreadAnnouncement({`
`853`	`854`	`callGateway,`
`854`	`855`	`sessionId: "requester-session-2",`
`855`	`856`	`isActive: false,`
`856`	`857`	`expectsCompletionMessage: true,`
`857`	`858`	`directIdempotencyKey: "announce-1b",`
	`859`	`+ queueEmbeddedPiMessageWithOutcome,`
`858`	`860`	`});`
`859`	`861`
`860`	`862`	`expectGatewayAgentParams(callGateway, {`
`@@ -865,6 +867,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => {`
`865`	`867`	`threadId: "171.222",`
`866`	`868`	`bestEffortDeliver: true,`
`867`	`869`	`});`
	`870`	`+expect(queueEmbeddedPiMessageWithOutcome).not.toHaveBeenCalled();`
`868`	`871`	`});`
`869`	`872`
`870`	`873`	`it("uses in-process agent dispatch for dormant completion requesters", async () => {`
`@@ -1389,7 +1392,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => {`
`1389`	`1392`	`const result = await deliverSlackChannelAnnouncement({`
`1390`	`1393`	`callGateway,`
`1391`	`1394`	`sessionId: "requester-session-channel",`
`1392`		`-isActive: false,`
	`1395`	`+isActive: true,`
`1393`	`1396`	`expectsCompletionMessage: true,`
`1394`	`1397`	`directIdempotencyKey: "announce-channel-empty-direct-steer-fallback",`
`1395`	`1398`	`queueEmbeddedPiMessageWithOutcome,`

Original file line number	Diff line number	Diff line change
`@@ -457,8 +457,8 @@ async function maybeSteerSubagentAnnounce(params: {`
`457`	`457`	`}`
`458`	`458`	`const { cfg, entry } = loadRequesterSessionEntry(params.requesterSessionKey);`
`459`	`459`	`const canonicalKey = resolveRequesterStoreKey(cfg, params.requesterSessionKey);`
`460`		`-const { sessionId } = resolveRequesterSessionActivity(canonicalKey);`
`461`		`-if (!sessionId) {`
	`460`	`+const { sessionId, isActive } = resolveRequesterSessionActivity(canonicalKey);`
	`461`	`+if (!sessionId \|\| !isActive) {`
`462`	`462`	`return { status: "none" };`
`463`	`463`	`}`
`464`	`464`
`@@ -691,7 +691,11 @@ async function sendSubagentAnnounceDirectly(params: {`
`691`	`691`	`directOrigin?.channel,`
`692`	`692`	`sessionEntry: requesterEntry,`
`693`	`693`	`});`
`694`		`-if (params.expectsCompletionMessage && requesterActivity.sessionId) {`
	`694`	`+if (`
	`695`	`+params.expectsCompletionMessage &&`
	`696`	`+requesterActivity.sessionId &&`
	`697`	`+requesterActivity.isActive`
	`698`	`+) {`
`695`	`699`	`const wakeOutcome = await resolveQueueEmbeddedPiMessageOutcome(`
`696`	`700`	`requesterActivity.sessionId,`
`697`	`701`	`params.triggerMessage,`
`@@ -715,14 +719,12 @@ async function sendSubagentAnnounceDirectly(params: {`
`715`	`719`	`path: "steered",`
`716`	`720`	`};`
`717`	`721`	`}`
`718`		`-if (requesterActivity.isActive) {`
`719`		`-defaultRuntime.log(`
`720`		-`[warn] Active requester session could not be woken for subagent completion; falling back to requester-agent handoff: ${formatQueueWakeFailureError(
`721`		`- "active requester session could not be woken",`
`722`		`- wakeOutcome,`
`723`		- )}`,
`724`		`-);`
`725`		`-}`
	`722`	`+defaultRuntime.log(`
	`723`	+`[warn] Active requester session could not be woken for subagent completion; falling back to requester-agent handoff: ${formatQueueWakeFailureError(
	`724`	`+ "active requester session could not be woken",`
	`725`	`+ wakeOutcome,`
	`726`	+ )}`,
	`727`	`+);`
`726`	`728`	`}`
`727`	`729`	`if (params.signal?.aborted) {`
`728`	`730`	`return {`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main