diff --git a/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflow.java b/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflow.java index c9a9af455..4c1ac8ddb 100644 --- a/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflow.java +++ b/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflow.java @@ -15,6 +15,10 @@ package io.dapr.examples.workflows.childworkflow; import io.dapr.workflows.Workflow; import io.dapr.workflows.WorkflowStub; +import io.dapr.workflows.WorkflowTaskOptions; +import io.dapr.workflows.WorkflowTaskRetryPolicy; + +import java.time.Duration; public class DemoChildWorkflow implements Workflow { @Override @@ -22,11 +26,18 @@ public class DemoChildWorkflow implements Workflow { return ctx -> { ctx.getLogger().info("Starting ChildWorkflow: " + ctx.getName()); + WorkflowTaskRetryPolicy policy = WorkflowTaskRetryPolicy.newBuilder() + .setFirstRetryInterval(Duration.ofSeconds(1)) + .setMaxNumberOfAttempts(10) + .build(); + + WorkflowTaskOptions options = new WorkflowTaskOptions(policy); + var childWorkflowInput = ctx.getInput(String.class); ctx.getLogger().info("ChildWorkflow received input: " + childWorkflowInput); ctx.getLogger().info("ChildWorkflow is calling Activity: " + ReverseActivity.class.getName()); - String result = ctx.callActivity(ReverseActivity.class.getName(), childWorkflowInput, String.class).await(); + String result = ctx.callActivity(ReverseActivity.class.getName(), childWorkflowInput, options, String.class).await(); ctx.getLogger().info("ChildWorkflow finished with: " + result); ctx.complete(result); diff --git a/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflowWorker.java b/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflowWorker.java index 0e692551e..dce40e97e 100644 --- a/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflowWorker.java +++ b/examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflowWorker.java @@ -32,6 +32,7 @@ public class DemoChildWorkflowWorker { // Build and then start the workflow runtime pulling and executing tasks WorkflowRuntime runtime = builder.build(); + runtime.start(); System.out.println("Start workflow runtime"); } } diff --git a/sdk-workflows/pom.xml b/sdk-workflows/pom.xml index 0a5289daf..e763e7630 100644 --- a/sdk-workflows/pom.xml +++ b/sdk-workflows/pom.xml @@ -47,7 +47,7 @@ io.dapr durabletask-client - 1.5.2 + 1.5.3