diff --git a/packages/core/test/database-migration.test.ts b/packages/core/test/database-migration.test.ts
index 1a313051bb0..3d5c3f87594 100644
--- a/packages/core/test/database-migration.test.ts
+++ b/packages/core/test/database-migration.test.ts
@@ -1018,7 +1018,10 @@ describe("DatabaseMigration", () => {
           }),
         ).pipe(
           Effect.provide(
-            AppNodeBuilder.build(LayerNode.group([Bus.node, SessionProjector.node]), [[Database.node, database]]),
+            AppNodeBuilder.build(LayerNode.group([Bus.node, SessionProjector.node]), [
+              [Database.node, database],
+              [Bus.node, Bus.configured({ persist: true })],
+            ]),
           ),
         )
 
diff --git a/packages/core/test/session-log.test.ts b/packages/core/test/session-log.test.ts
index e72ff388e0d..7728cf72487 100644
--- a/packages/core/test/session-log.test.ts
+++ b/packages/core/test/session-log.test.ts
@@ -46,7 +46,9 @@ describe("Session.log", () => {
 
       const items = Array.from(yield* Stream.runCollect(session.log({ sessionID: created.id })))
 
-      expect(items.map((item) => item.type)).toEqual(["session.created", "session.renamed", "log.synced"])
+      // Session creation commits a non-public durable event, so the marker's
+      // seq covers more of the aggregate than the public events emitted.
+      expect(items.map((item) => item.type)).toEqual(["session.renamed", "log.synced"])
       expect(items.at(-1)).toEqual({ type: "log.synced", aggregateID: created.id, seq: Event.Seq.make(1) })
     }),
   )