io.temporal.workflow.Workflow.newTimer(Duration.parse("PT5S")); raises exception

Community Support
1

Hi,

When I am trying to create a timer, using the above syntax I am seeing the following exception, I am trying to create a Delay of 5 seconds without an await condition

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

Any suggestions?

Thanks,

Kasi

2

In which method of the workflow are you calling newTimer function? Would you post the full stack trace of the exception?

3

in the starting workflow method, the first execution is introducing a timer delay,
startWorkflow is a workflow method,

public String startWorkflow(String data) {

    // will have to call other activities and stuff here
    System.out.println("Inside workflow");
    this.data = data;
    // we need a state machine which navigates thru the actions
    io.temporal.workflow.Workflow.newTimer(Duration.parse("PT5S"));

The exception thrown is part of java.lang.reflect.InvocationTargetException.

Thanks,

Kasi

4

Also, on a separate note, I used to be able to run the workflow in IDEA debugger, now I am seeing deadlock exception when running in debugger

5

I’ve just tested Workflow.newTimer and it worked fine for me. What is the stack trace of the IllegalStateException?

BTW. Workflow.newTimer(Duration.parse("PT5S")) returns a Promise that you are ignoring in the above sample, so your code is not going to block. Either call get on the returned promise or use Workflow.sleep.

Also, on a separate note, I used to be able to run the workflow in IDEA debugger, now I am seeing deadlock exception when running in debugger

Add TEMPORAL_DEBUG=true environment variable to disable the deadlock detector.

6

Workflow.sleep throws the same exception.

7

Then to help you we need at least the exception stack trace.

8

Hi Maxim,

Here is a snapshot of the error, can we webex for 10 minutes on this?

Thanks,

Kasi

Screen Shot 2021-02-02 at 8.09.01 AM
Screen Shot 2021-02-02 at 8.09.01 AM1808×548 87.9 KB

9

I made changes to existing HelloActivity from temporal samples project,

@Override
    public String getGreeting(String name) {
      // This is a blocking call that returns only after the activity has completed.
      Workflow.sleep(Duration.parse("PT5S"));
      Workflow.await(Duration.parse("PT5S"), () -> proceed);
      return activities.composeGreeting("Hello", name);
    }

running into same issue.

Thanks,

Kasi

10

I did the same change to the HelloAtivity and it runs fine for me. Would you point me to the repository with the code that reproduces your issue?