diff --git a/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs b/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs
index a7d8280..552b14f 100644
--- a/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs
+++ b/tests/Akka.Persistence.Migration.Tests/PersistenceWriterActorSpec.cs
@@ -190,9 +190,6 @@ await WithJournalWrite(behavior => behavior.SetInterceptorAsync(new RepeatJourna
             var probe = CreateTestProbe();
             writer.Tell(CreateEnvelopeFor(1, 1), probe);
             probe!.ExpectMsg<PersistenceWriterProtocol.PersistFailed>();
-                
-            await WatchAsync(writer);
-            await ExpectTerminatedAsync(writer);
         });
     }
     
@@ -267,9 +264,6 @@ await WithSnapshotSave(behavior => behavior.SetInterceptorAsync(new RepeatSnapsh
             var probe = CreateTestProbe();
             writer.Tell(new SelectedSnapshot(new SnapshotMetadata("a", 999), 6), probe);
             probe!.ExpectMsg<PersistenceWriterProtocol.SnapshotFailed>();
-            
-            await WatchAsync(writer);
-            await ExpectTerminatedAsync(writer);
         });
     }