chore: Use latest durabletask-java version

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

Author: javier-aliaga

sdk-tests/src/test/java/io/dapr/it/testcontainers/TaskExecutionKeyActivity.java renamed to sdk-tests/src/test/java/io/dapr/it/testcontainers/TaskExecutionIdActivity.java

@@ -16,15 +16,15 @@
 import io.dapr.workflows.WorkflowActivity;
 import io.dapr.workflows.WorkflowActivityContext;
 
-public class TaskExecutionKeyActivity implements WorkflowActivity {
+public class TaskExecutionIdActivity implements WorkflowActivity {
 
   @Override
   public Object run(WorkflowActivityContext ctx) {
     TestWorkflowPayload workflowPayload = ctx.getInput(TestWorkflowPayload.class);
     KeyStore keyStore = KeyStore.getInstance();
-    Boolean exists = keyStore.getKey(ctx.getTaskExecutionKey());
+    Boolean exists = keyStore.getKey(ctx.getTaskExecutionId());
     if (!Boolean.TRUE.equals(exists)) {
-      keyStore.addKey(ctx.getTaskExecutionKey(), true);
+      keyStore.addKey(ctx.getTaskExecutionId(), true);
       workflowPayload.getPayloads().add("Execution key not found");
       throw new IllegalStateException("Task execution key not found");
     }

sdk-tests/src/test/java/io/dapr/it/testcontainers/TestExecutionKeysWorkflow.java

@@ -47,7 +47,7 @@ public WorkflowStub create() {
       .build());
 
 
-      Task<TestWorkflowPayload> t =   ctx.callActivity(TaskExecutionKeyActivity.class.getName(), workflowPayload, options,TestWorkflowPayload.class);
+      Task<TestWorkflowPayload> t =   ctx.callActivity(TaskExecutionIdActivity.class.getName(), workflowPayload, options,TestWorkflowPayload.class);
 
       TestWorkflowPayload payloadAfterExecution = t.await();
 

sdk-tests/src/test/java/io/dapr/it/testcontainers/workflows/TestWorkflowsConfiguration.java

@@ -59,7 +59,7 @@ public WorkflowRuntimeBuilder workflowRuntimeBuilder(
     builder.registerWorkflow(TestExecutionKeysWorkflow.class);
     builder.registerActivity(FirstActivity.class);
     builder.registerActivity(SecondActivity.class);
-    builder.registerActivity(TaskExecutionKeyActivity.class);
+    builder.registerActivity(TaskExecutionIdActivity.class);
 
 
     return builder;

sdk-workflows/pom.xml

@@ -47,7 +47,7 @@
     <dependency>
       <groupId>io.dapr</groupId>
       <artifactId>durabletask-client</artifactId>
-      <version>1.5.6</version>
+      <version>1.5.7</version>
     </dependency>
     <!--
     manually declare durabletask-client's jackson dependencies

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

@@ -17,7 +17,7 @@ public interface WorkflowActivityContext {
 
   String getName();
 
-  String getTaskExecutionKey();
+  String getTaskExecutionId();
 
   <T> T getInput(Class<T> targetType);
 

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

@@ -58,7 +58,7 @@ public <T> T getInput(Class<T> targetType) {
   }
 
   @Override
-  public String getTaskExecutionKey() {
-    return this.innerContext.getTaskExecutionKey();
+  public String getTaskExecutionId() {
+    return this.innerContext.getTaskExecutionId();
   }
 }

sdk-workflows/src/test/java/io/dapr/workflows/runtime/WorkflowActivityClassWrapperTest.java

@@ -16,7 +16,7 @@ public static class TestActivity implements WorkflowActivity {
     @Override
     public Object run(WorkflowActivityContext ctx) {
       String activityContextName = ctx.getName();
-      return ctx.getInput(String.class) + " world! from " + activityContextName + " with task execution key " + ctx.getTaskExecutionKey();
+      return ctx.getInput(String.class) + " world! from " + activityContextName + " with task execution key " + ctx.getTaskExecutionId();
     }
   }
 
@@ -37,7 +37,7 @@ public void createWithClass() {
 
     when(mockContext.getInput(String.class)).thenReturn("Hello");
     when(mockContext.getName()).thenReturn("TestActivityContext");
-    when(mockContext.getTaskExecutionKey()).thenReturn("123");
+    when(mockContext.getTaskExecutionId()).thenReturn("123");
 
     Object result = wrapper.create().run(mockContext);