chore: Propagate traceparent to workflow activity

Signed-off-by: Javier Aliaga <[email protected]>

Author: javier-aliaga

durabletask-client/pom.xml

@@ -121,32 +121,24 @@
         </executions>
       </plugin>
       <plugin>
-        <groupId>io.github.ascopes</groupId>
+        <groupId>org.xolstice.maven.plugins</groupId>
         <artifactId>protobuf-maven-plugin</artifactId>
         <version>${protobuf-maven-plugin.version}</version>
         <configuration>
-          <protocVersion>${protobuf.version}</protocVersion>
-          <embedSourcesInClassOutputs>true</embedSourcesInClassOutputs>
-          <sourceDirectories>
-            <sourceDirectory>${protobuf.input.directory}</sourceDirectory>
-          </sourceDirectories>
-          <binaryMavenPlugins>
-            <binaryMavenPlugin>
-              <groupId>io.grpc</groupId>
-              <artifactId>protoc-gen-grpc-java</artifactId>
-              <version>${grpc.version}</version>
-            </binaryMavenPlugin>
-          </binaryMavenPlugins>
+          <protocArtifact>com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier}</protocArtifact>
+          <pluginId>grpc-java</pluginId>
+          <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}</pluginArtifact>
+          <protoSourceRoot>${protobuf.input.directory}</protoSourceRoot>
         </configuration>
         <executions>
           <execution>
             <goals>
-              <goal>generate</goal>
+              <goal>compile</goal>
+              <goal>compile-custom</goal>
             </goals>
           </execution>
         </executions>
       </plugin>
-
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-source-plugin</artifactId>

durabletask-client/src/main/java/io/dapr/durabletask/DurableTaskGrpcClient.java

@@ -29,7 +29,7 @@
 import io.grpc.netty.GrpcSslContexts;
 import io.grpc.netty.NettyChannelBuilder;
 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
-import io.opentelemetry.api.OpenTelemetry;
+import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.Tracer;
 
@@ -140,7 +140,8 @@ public final class DurableTaskGrpcClient extends DurableTaskClient {
     if (builder.tracer != null) {
       this.tracer = builder.tracer;
     } else {
-      this.tracer = OpenTelemetry.noop().getTracer("DurableTaskGrpcClient");
+      //this.tracer = OpenTelemetry.noop().getTracer("DurableTaskGrpcClient");
+      this.tracer = GlobalOpenTelemetry.getTracer("dapr-workflow");
     }
 
     this.sidecarClient = TaskHubSidecarServiceGrpc.newBlockingStub(sidecarGrpcChannel);

durabletask-client/src/main/java/io/dapr/durabletask/util/TraceUtils.java

@@ -0,0 +1,5 @@
+package io.dapr.durabletask.util;
+
+public class TraceUtils {
+
+}

pom.xml

@@ -16,7 +16,7 @@
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <grpc.version>1.69.0</grpc.version>
     <protobuf.version>3.25.5</protobuf.version>
-    <dapr.proto.baseurl>https://raw.githubusercontent.com/dapr/dapr/master/dapr/proto</dapr.proto.baseurl>
+    <dapr.proto.baseurl>https://raw.githubusercontent.com/dapr/dapr/v1.16.0-rc.5/dapr/proto</dapr.proto.baseurl>
     <durabletask.proto.url>https://raw.githubusercontent.com/dapr/durabletask-protobuf/main/protos/orchestrator_service.proto</durabletask.proto.url>
     <dapr.sdk.version>1.17.0-SNAPSHOT</dapr.sdk.version>
     <os-maven-plugin.version>1.7.1</os-maven-plugin.version>

sdk-workflows/src/main/java/io/dapr/workflows/WorkflowActivityContext.java

@@ -25,4 +25,5 @@ public interface WorkflowActivityContext {
 
   <T> T getInput(Class<T> targetType);
 
+  String getTraceParent();
 }

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowActivityContext.java

@@ -97,6 +97,11 @@ public <T> T getInput(Class<T> targetType) {
     return this.innerContext.getInput(targetType);
   }
 
+  @Override
+  public String getTraceParent() {
+    return this.innerContext.getTraceParent();
+  }
+
   @Override
   public String getTaskExecutionId() {
     return this.innerContext.getTaskExecutionId();