diff --git a/tests/e2e/migrations/test_rolling_upgrade.py b/tests/e2e/migrations/test_rolling_upgrade.py
index 4d60d20df4a..5ad74e0ba8c 100644
--- a/tests/e2e/migrations/test_rolling_upgrade.py
+++ b/tests/e2e/migrations/test_rolling_upgrade.py
@@ -32,6 +32,8 @@ class TestRollingUpgrade:
                     ready((new,), baseline_database)
                     assert_upgraded(before, migration_names(baseline_database))
                     keep_serving(traffic, "the baseline replica authenticating after the schema moved")
+                    with auth_traffic(old, provision(new)[0]) as uncached:
+                        keep_serving(uncached, "the baseline replica resolving a key minted after the schema moved")
             assert_history_clean(baseline_database)
             assert CACHED_PLAN not in old.logs(), "The baseline replica hit a stale prepared statement"
             assert old.state().Running, "The baseline replica died during the upgrade"
diff --git a/tests/e2e/migrations/upgrade.py b/tests/e2e/migrations/upgrade.py
index 2758d0fb974..2123f86450a 100644
--- a/tests/e2e/migrations/upgrade.py
+++ b/tests/e2e/migrations/upgrade.py
@@ -88,6 +88,9 @@ def auth_traffic(replica: Replica, key: str, interval: float = 0.05) -> Generato
         stop.set()
         thread.join(30)
         assert not thread.is_alive(), "Auth traffic thread did not stop"
+    assert not outcomes.failures, (
+        f"Virtual-key auth failed on {replica.name} after the traffic window closed: {outcomes.failures[:5]}"
+    )
 
 
 def keep_serving(outcomes: Outcomes, description: str, calls: int = 20) -> int:
@@ -105,6 +108,10 @@ def assert_history_clean(database: Database) -> None:
     assert database.query(
         "SELECT count(*) FROM _prisma_migrations WHERE finished_at IS NULL OR rolled_back_at IS NOT NULL"
     ) == ((0,),), "The upgrade left an unfinished or rolled-back migration behind"
+    assert database.query(
+        "SELECT count(*) FROM (SELECT migration_name FROM _prisma_migrations GROUP BY migration_name "
+        "HAVING count(*) > 1) duplicated"
+    ) == ((0,),), "A migration was recorded more than once, so it ran on more than one replica"
 
 
 def assert_upgraded(before: frozenset[str], after: frozenset[str]) -> frozenset[str]: