R2dbcJournalPerfSpec pending for sqlserver

akka · Feb 2, 2024 · 8743aaa · 8743aaa
1 parent 8224add
commit 8743aaa
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/core/src/test/scala/akka/persistence/r2dbc/journal/R2dbcJournalPerfSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/journal/R2dbcJournalPerfSpec.scala
@@ -6,6 +6,9 @@ package akka.persistence.r2dbc.journal
 
 import scala.concurrent.duration._
 
+import org.scalatest.exceptions.TestPendingException
+
+import akka.actor.ActorRef
 import akka.actor.typed.ActorSystem
 import akka.actor.typed.scaladsl.adapter._
 import akka.persistence.CapabilityFlag
@@ -26,4 +29,11 @@ class R2dbcJournalPerfSpec extends JournalPerfSpec(R2dbcJournalPerfSpec.config)
   override protected def supportsRejectingNonSerializableObjects: CapabilityFlag = CapabilityFlag.off()
 
   override def typedSystem: ActorSystem[_] = system.toTyped
+
+  override def benchActor(replyAfter: Int): ActorRef = {
+    if (r2dbcSettings.dialectName == "sqlserver")
+      throw new TestPendingException
+    else
+      super.benchActor(replyAfter)
+  }
 }