diff --git a/instrumentation/akka-context-propagation/akka-context-propagation.gradle b/instrumentation/akka-context-propagation/akka-context-propagation.gradle index 28ef8af949..ce9c59c061 100644 --- a/instrumentation/akka-context-propagation/akka-context-propagation.gradle +++ b/instrumentation/akka-context-propagation/akka-context-propagation.gradle @@ -1,3 +1,7 @@ +ext { + retryTests = true +} + apply from: "$rootDir/gradle/instrumentation.gradle" apply from: "$rootDir/gradle/test-with-scala.gradle" diff --git a/instrumentation/akka-context-propagation/src/test/groovy/AkkaExecutorInstrumentationTest.groovy b/instrumentation/akka-context-propagation/src/test/groovy/AkkaExecutorInstrumentationTest.groovy index 44fd7fd6b3..ddb64c0c89 100644 --- a/instrumentation/akka-context-propagation/src/test/groovy/AkkaExecutorInstrumentationTest.groovy +++ b/instrumentation/akka-context-propagation/src/test/groovy/AkkaExecutorInstrumentationTest.groovy @@ -52,7 +52,7 @@ class AkkaExecutorInstrumentationTest extends AgentTestRunner { @Shared def akkaInvokeForkJoinTask = { e, c -> e.invoke((ForkJoinTask) c) } - def "#poolImpl '#name' propagates"() { + def "#poolName '#name' propagates"() { setup: def pool = poolImpl def m = method @@ -100,9 +100,10 @@ class AkkaExecutorInstrumentationTest extends AgentTestRunner { "submit Callable" | submitCallable | new ForkJoinPool() "submit ForkJoinTask" | akkaSubmitForkJoinTask | new ForkJoinPool() "invoke ForkJoinTask" | akkaInvokeForkJoinTask | new ForkJoinPool() + poolName = poolImpl.class.name } - def "#poolImpl '#name' reports after canceled jobs"() { + def "ForkJoinPool '#name' reports after canceled jobs"() { setup: def pool = poolImpl def m = method