diff --git a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/build.gradle b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/build.gradle index d1e796ba315..a68a645badb 100644 --- a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/build.gradle +++ b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/build.gradle @@ -8,10 +8,16 @@ plugins { // we put the test classes in the baseTest test set so that the scala // version is not inherited addTestSuite('baseTest') +addForkedTestTask('baseTest') + addTestSuite('latestDepTest') +addForkedTestTask('latestDepTest') + addTestSuiteForDir('latestPekko10Test', 'latestDepTest') +addForkedTestTask('latestPekko10Test') + addTestSuite('iastTest') -addTestSuiteForDir 'latestDepIastTest', 'iastTest' +addTestSuiteForDir('latestDepIastTest', 'iastTest') muzzle { pass { diff --git a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/baseTest/groovy/PekkoHttpClientInstrumentationTest.groovy b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/baseTest/groovy/PekkoHttpClientInstrumentationTest.groovy index 628ccbd366b..6d661d7e682 100644 --- a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/baseTest/groovy/PekkoHttpClientInstrumentationTest.groovy +++ b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/baseTest/groovy/PekkoHttpClientInstrumentationTest.groovy @@ -73,14 +73,14 @@ abstract class PekkoHttpClientInstrumentationTest extends HttpClientTest { span { parent() operationName operation() - resourceName "pekko-http.client.request" + resourceName operation() // resource name is not set so defaults to operationName spanType DDSpanTypes.HTTP_CLIENT errored true tags { "$Tags.COMPONENT" "pekko-http-client" "$Tags.SPAN_KIND" Tags.SPAN_KIND_CLIENT errorTags(exception) - defaultTags() + defaultTags(false, false) } } } diff --git a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/main/java/datadog/trace/instrumentation/pekkohttp/PekkoHttpSingleRequestInstrumentation.java b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/main/java/datadog/trace/instrumentation/pekkohttp/PekkoHttpSingleRequestInstrumentation.java index 4625cdfe955..1c85e382736 100644 --- a/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/main/java/datadog/trace/instrumentation/pekkohttp/PekkoHttpSingleRequestInstrumentation.java +++ b/dd-java-agent/instrumentation/pekko/pekko-http-1.0/src/main/java/datadog/trace/instrumentation/pekkohttp/PekkoHttpSingleRequestInstrumentation.java @@ -115,6 +115,9 @@ public static class SingleRequestContextPropagationAdvice { @Advice.OnMethodEnter(suppress = Throwable.class) public static void methodEnter( @Advice.Argument(value = 0, readOnly = false) HttpRequest request) { + if (request == null) { + return; + } final PekkoHttpHeaders headers = new PekkoHttpHeaders(request); DECORATE.injectContext(currentContext(), request, headers); request = headers.getRequest();