You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@maka.apache.org by as...@apache.org on 2026/08/24 04:44:34 UTC
(maka) 10/20: test: settle durable steering projection cleanup
This is an automated email from the ASF dual-hosted git repository.
Astro-Han pushed a commit to branch fix/steering-durable-admission
in repository https://gitbox.apache.org/repos/asf/maka.git
commit c245a01317481d43b61eadf47ea4544dc55878f8
Author: AstroHan <le...@outlook.com>
AuthorDate: Sun Aug 23 23:03:41 2026 +0800
test: settle durable steering projection cleanup
Generated-by: Maka
---
.../src/__tests__/canonical-session-projection.test.ts | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/packages/runtime-host/src/__tests__/canonical-session-projection.test.ts b/packages/runtime-host/src/__tests__/canonical-session-projection.test.ts
index 3c4131aa6..b36e88f79 100644
--- a/packages/runtime-host/src/__tests__/canonical-session-projection.test.ts
+++ b/packages/runtime-host/src/__tests__/canonical-session-projection.test.ts
@@ -145,11 +145,14 @@ test('projects the canonical root lifecycle and the attachment queue from real S
terminalEventId: terminal.id,
});
- await messages.handlers['queue.retract'](
- { originHostEpoch: 'epoch-1', sessionId: session.id, retractId: 'cleanup' },
- operationContext(),
- );
- messages.abandonRootReservation({ sessionId: session.id, turnId: 'turn-1', runId: 'run-1' });
+ const identity = { sessionId: session.id, turnId: 'turn-1', runId: 'run-1' };
+ const owner = messages.bindRun(identity);
+ const leases = owner.pull();
+ owner.ack(leases.map((lease) => lease.id));
+ owner.release();
+ const batch = messages.beginTerminalTransition(identity);
+ assert.equal(batch.sources.length, 0);
+ messages.completeIdle(batch);
await messages.close();
});
});
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@maka.apache.org
For additional commands, e-mail: commits-help@maka.apache.org