diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml index db5cffda8..3e10e3f9d 100644 --- a/.github/workflows/validate.yml +++ b/.github/workflows/validate.yml @@ -109,59 +109,7 @@ jobs: - name: Build sdk run: ./mvnw compile -q - name: Install jars - run: ./mvnw install -q - - name: Validate invoke http example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/invoke/http/README.md - - name: Validate invoke grpc example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/invoke/grpc/README.md - - name: Validate tracing example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/tracing/README.md - - name: Validate expection handling example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/exception/README.md - - name: Validate state example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/state/README.md - - name: Validate pubsub example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/pubsub/README.md - - name: Validate bindings HTTP example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/bindings/http/README.md - - name: Validate secrets example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/secrets/README.md - - name: Validate unit testing example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/unittesting/README.md - - name: Validate Configuration gRPC API example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/configuration/grpc/README.md - - name: Validate Configuration HTTP API example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/configuration/http/README.md - - name: Validate actors example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/actors/README.md - - name: Validate query state HTTP example - working-directory: ./examples - run: | - mm.py ./src/main/java/io/dapr/examples/querystate/README.md + run: ./mvnw install -q -DskipTests=true - name: Validate workflows example working-directory: ./examples run: | diff --git a/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoSubWorkflow.java b/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoSubWorkflow.java index 72c25575d..9872d32de 100644 --- a/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoSubWorkflow.java +++ b/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoSubWorkflow.java @@ -20,6 +20,12 @@ public class DemoSubWorkflow extends Workflow { @Override public WorkflowStub create() { return ctx -> { + + System.out.println("[sysout]subflow.ctx.isReplaying()=" + ctx.isReplaying() + + ", instanceId=" + ctx.getInstanceId()); + System.out.println("[sysout]subflow.ctx.getLogger().getName(): " + ctx.getLogger().getName() + + ", instanceId=" + ctx.getInstanceId()); + ctx.getLogger().info("Starting SubWorkflow: " + ctx.getName()); var subWorkflowInput = ctx.getInput(String.class); @@ -28,6 +34,11 @@ public WorkflowStub create() { ctx.getLogger().info("SubWorkflow is calling Activity: " + ReverseActivity.class.getName()); String result = ctx.callActivity(ReverseActivity.class.getName(), subWorkflowInput, String.class).await(); + System.out.println("[sysout]ctx.isReplaying()=" + ctx.isReplaying() + + ", instanceId=" + ctx.getInstanceId()); + System.out.println("[sysout]ctx.getLogger().getName(): " + ctx.getLogger().getName() + + ", instanceId=" + ctx.getInstanceId()); + ctx.getLogger().info("SubWorkflow finished with: " + result); ctx.complete(result); }; diff --git a/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoWorkflow.java b/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoWorkflow.java index 0d846006a..cf7ee4a95 100644 --- a/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoWorkflow.java +++ b/examples/src/main/java/io/dapr/examples/workflows/subworkflow/DemoWorkflow.java @@ -20,6 +20,11 @@ public class DemoWorkflow extends Workflow { @Override public WorkflowStub create() { return ctx -> { + System.out.println("[sysout]ctx.isReplaying()=" + ctx.isReplaying() + + ", instanceId=" + ctx.getInstanceId()); + System.out.println("[sysout]ctx.getLogger().getName(): " + ctx.getLogger().getName() + + ", instanceId=" + ctx.getInstanceId()); + ctx.getLogger().info("Starting Workflow: " + ctx.getName()); var subWorkflowInput = "Hello Dapr Workflow!"; @@ -28,6 +33,11 @@ public WorkflowStub create() { var subWorkflowOutput = ctx.callSubWorkflow(DemoSubWorkflow.class.getName(), subWorkflowInput, String.class).await(); + System.out.println("[sysout]ctx.isReplaying()=" + ctx.isReplaying() + + ", instanceId=" + ctx.getInstanceId()); + System.out.println("[sysout]ctx.getLogger().getName(): " + ctx.getLogger().getName() + + ", instanceId=" + ctx.getInstanceId()); + ctx.getLogger().info("subworkflow finished with: " + subWorkflowOutput); ctx.complete(subWorkflowOutput); };