Can a child workflow/activity be triggered from a Workflow CancellationScope in the exception block?

anjo · March 19, 2021, 10:08am

Thanku again.

I am trying to unit test the same scenario, cancel scenario with a mock for the CleanupWorkflow.

I get the error

java.lang.IllegalStateException: Operation allowed only while eventLoop is running

Sample code is here :

ansujohn/samples-java/blob/SignalWF_Test/src/test/java/io/temporal/samples/helloSignal/HelloSignalWorkflowTest.java#L85


      
            workflow.signalChange("INIT");
            workflow.signalChange("STATE1");
            workflow.signalChange("STATE2");
            workflow.signalChange("STATE3");
            testEnv.sleep(Duration.ofSeconds(2));
          
            verify(greetingActivity, times(4)).composeGreeting(any());
          }
          
          @Test
          public void testCancellation() {
          
            GreetingActivity greetingActivity = mock(GreetingActivity.class);
            when(greetingActivity.composeGreeting(anyString())).thenReturn("Hello Test");
            worker.registerActivitiesImplementations(greetingActivity);
          
            // As new mock is created on each workflow task the only last one is useful to verify calls.
            AtomicReference<CleanupWorkflow> lastChildMock = new AtomicReference<>();
            // Factory is called to create a new workflow object on each workflow task.
            worker.addWorkflowImplementationFactory(
                CleanupWorkflow.class,

I have used mocking workflow example from here - https://github.com/temporalio/samples-java/blob/986f4965ca9799af36784f80e28a7a04c0e6f9eb/src/test/java/io/temporal/samples/hello/HelloChildTest.java

Also get this error Argument passed to verify() should be a mock but is null!

github.com

ansujohn/samples-java/blob/SignalWF_Test/src/test/java/io/temporal/samples/helloSignal/HelloSignalWorkflowTest.java#L124


      
          
              // Start workflow
              WorkflowClient.start(workflow::start);
          
              workflow.signalChange("INIT");
              workflow.signalChange("STATE1");
              testEnv.sleep(Duration.ofSeconds(2));
              client.newUntypedWorkflowStub(wfId.toString(), empty(), empty()).cancel();
              testEnv.sleep(Duration.ofSeconds(2));
              verify(greetingActivity, times(2)).composeGreeting(any());
              CleanupWorkflow cleanupWorkflow = lastChildMock.get();
              verify(cleanupWorkflow, times(1)).cleanUp(anyList());
            }
          }

Topic		Replies	Views
Accessing parent cancellation scopes Community Support java-sdk	7	165	December 28, 2023
Cancel child workflow from parent Community Support java-sdk	2	466	November 17, 2021
Trouble with workflow cancellation Community Support java-sdk	10	2693	April 18, 2024
Using "finally" in the try catch block of parent workflow executing a sequence of child workflows Community Support java-sdk , general-impl	1	635	September 28, 2022
When a Workflow is cancelled, how is the ongoing execution handled? Community Support general-impl , workflow-options	5	5918	December 13, 2022

Can a child workflow/activity be triggered from a Workflow CancellationScope in the exception block?

Related Topics