raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #30468 from andreaTP/excludes-on-gha

Browse source 
Exclude failing tests only on GHA
This commit is contained in:
Andrea Peruffo 2021-08-04 15:52:37 +02:00 • committed by GitHub
commit 60e8225059
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
6 changed files with 15 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
.github/workflows/scala3-build.yml vendored
View file

@ -30,7 +30,7 @@ jobs:
sbt -jvm-opts .jvmopts-ci \
-Dakka.build.scalaVersion=3.0 \
-Dakka.test.multi-in-test=false \
-Dakka.test.tags.exclude=performance,timing,long-running \
-Dakka.test.tags.exclude=performance,timing,long-running,gh-exclude \
akka-actor-tests/test \
akka-actor-testkit-typed/test \
akka-actor-typed/compile \

5
akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala
View file

@ -10,7 +10,7 @@ import com.typesafe.config.ConfigFactory
import language.postfixOps
import akka.actor._
import akka.testkit.{ AkkaSpec, TestProbe }
import akka.testkit.{ AkkaSpec, GHExcludeTest, TestProbe }
object EventStreamSpec {
@ -315,7 +315,8 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
"unsubscribe the actor, when it subscribes already in terminated state" in {
// Excluded in GH Actions: https://github.com/akka/akka/issues/30460
"unsubscribe the actor, when it subscribes already in terminated state" taggedAs GHExcludeTest in {
val sys = ActorSystem("EventStreamSpecUnsubscribeTerminated", configUnhandledWithDebug)
try {

4
akka-actor-tests/src/test/scala/akka/io/UdpConnectedIntegrationSpec.scala
View file

@ -10,6 +10,7 @@ import scala.concurrent.duration._
import akka.actor.ActorRef
import akka.testkit.AkkaSpec
import akka.testkit.GHExcludeTest
import akka.testkit.ImplicitSender
import akka.testkit.SocketUtil.temporaryServerAddresses
import akka.testkit.TestProbe
@ -125,7 +126,8 @@ class UdpConnectedIntegrationSpec extends AkkaSpec("""
}
// #26903
"be able to send and receive when server goes away (and comes back)" in {
// Excluded in GH Actions: https://github.com/akka/akka/issues/30462
"be able to send and receive when server goes away (and comes back)" taggedAs GHExcludeTest in {
val addresses = temporaryServerAddresses(2, udp = true)
val serverAddress = addresses(0)
val clientAddress = addresses(1)

4
akka-actor-typed-tests/src/test/scala/akka/actor/typed/pubsub/LocalPubSubSpec.scala
View file

@ -8,6 +8,7 @@ import scala.concurrent.duration._
import org.scalatest.wordspec.AnyWordSpecLike
import akka.testkit.GHExcludeTest
import akka.actor.testkit.typed.scaladsl.LogCapturing
import akka.actor.testkit.typed.scaladsl.LoggingTestKit
import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
@ -17,7 +18,8 @@ class LocalPubSubSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike wit
"A pub-sub topic running locally" must {
"publish to all local subscriber actors of a topic" in {
// Excluded in GH Actions: https://github.com/akka/akka/issues/30466
"publish to all local subscriber actors of a topic" taggedAs GHExcludeTest in {
val fruitTopic =
LoggingTestKit.debug("Topic list updated").withCheckExcess(false).expect {
testKit.spawn(Topic[String]("fruit"))

5
akka-stream-tests/src/test/scala/akka/stream/scaladsl/HubSpec.scala
View file

@ -17,7 +17,7 @@ import akka.stream.testkit.Utils.TE
import akka.stream.testkit.scaladsl.StreamTestKit._
import akka.stream.testkit.scaladsl.TestSink
import akka.stream.testkit.scaladsl.TestSource
import akka.testkit.EventFilter
import akka.testkit.{ EventFilter, GHExcludeTest }
class HubSpec extends StreamSpec {
@ -199,7 +199,8 @@ class HubSpec extends StreamSpec {
downstream.expectComplete()
}
"immediately cancel new producers while draining" in assertAllStagesStopped {
// Excluded in GH Actions: https://github.com/akka/akka/issues/30464
"immediately cancel new producers while draining" taggedAs GHExcludeTest in assertAllStagesStopped {
val downstream = TestSubscriber.probe[Int]()
val (sink, draining) =
MergeHub.sourceWithDraining[Int](16).take(20).toMat(Sink.fromSubscriber(downstream))(Keep.left).run()

2
akka-testkit/src/test/scala/akka/testkit/TestTags.scala
View file

@ -9,3 +9,5 @@ import org.scalatest.Tag
object TimingTest extends Tag("timing")
object LongRunningTest extends Tag("long-running")
object PerformanceTest extends Tag("performance")
object GHExcludeTest extends Tag("gh-exclude")