From df4663867d8692fd6d347d09d0f87eefa2399669 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Mon, 4 Jan 2021 12:56:49 +0100 Subject: [PATCH] ScalaFutures timeout is too short MultiDcClusterSharding test (#29917) --- .../cluster/sharding/typed/MultiDcClusterShardingSpec.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala b/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala index 5e52393bd3..c56c128d91 100644 --- a/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala +++ b/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala @@ -5,10 +5,8 @@ package akka.cluster.sharding.typed import scala.concurrent.duration._ - import com.typesafe.config.ConfigFactory import org.scalatest.concurrent.ScalaFutures - import akka.actor.testkit.typed.scaladsl.TestProbe import akka.actor.typed.ActorRef import akka.cluster.MultiNodeClusterSpec @@ -58,6 +56,9 @@ abstract class MultiDcClusterShardingSpec import MultiDcClusterShardingSpecConfig._ import MultiDcPinger._ + override implicit def patienceConfig: PatienceConfig = + PatienceConfig(testKitSettings.DefaultTimeout.duration, 100.millis) + val typeKey = EntityTypeKey[Command]("ping") val entityId = "ping-1"