We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 97ed442 commit e02169bCopy full SHA for e02169b
1 file changed
apps/server/src/relay/AgentAwarenessRelay.ts
@@ -410,6 +410,11 @@ export const make = Effect.gen(function* () {
410
const publishIdentity = agentAwarenessPublishIdentity(snapshot.state);
411
const publishedStateByThread = yield* Ref.get(publishedStateByThreadRef);
412
if (publishedStateByThread.get(threadId) === publishIdentity) {
413
+ // The projection recovered to the last published state, so any deferred
414
+ // confirmation (tombstone or first-state completion) is moot. Clear the
415
+ // deadline so the next divergence gets a fresh deferral window instead
416
+ // of confirming immediately against a stale, expired deadline.
417
+ publishConfirmDeadlines.delete(threadId);
418
yield* Effect.logDebug("agent activity publish skipped; projected state unchanged", {
419
environmentId,
420
threadId,
0 commit comments