Hello,
I’m trying to run DSL workflow.
When I run a flow that executes an activity, I get following exception:
“Operation allowed only while eventLoop is running”
I am getting exception on executing dynamic activity:
activities.execute(action.getFunctionRef().getRefName(), ActResult.class, args)
Following is the error stacktrace:
{
"message": "Failure handling event 7 of type 'EVENT_TYPE_WORKFLOW_TASK_STARTED' during execution. {WorkflowTaskStartedEventId=7, CurrentStartedEventId=7}",
"source": "JavaSDK",
"stackTrace": "io.temporal.internal.statemachines.WorkflowStateMachines.createEventProcessingException(WorkflowStateMachines.java:373)\nio.temporal.internal.statemachines.WorkflowStateMachines.handleEventsBatch(WorkflowStateMachines.java:297)\nio.temporal.internal.statemachines.WorkflowStateMachines.handleEvent(WorkflowStateMachines.java:260)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.applyServerHistory(ReplayWorkflowRunTaskHandler.java:247)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.handleWorkflowTaskImpl(ReplayWorkflowRunTaskHandler.java:231)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.handleWorkflowTask(ReplayWorkflowRunTaskHandler.java:165)\nio.temporal.internal.replay.ReplayWorkflowTaskHandler.handleWorkflowTaskWithQuery(ReplayWorkflowTaskHandler.java:133)\nio.temporal.internal.replay.ReplayWorkflowTaskHandler.handleWorkflowTask(ReplayWorkflowTaskHandler.java:98)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handleTask(WorkflowWorker.java:413)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handle(WorkflowWorker.java:320)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handle(WorkflowWorker.java:261)\nio.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:105)\njava.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\njava.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\njava.base/java.lang.Thread.run(Thread.java:1589)\n",
"encodedAttributes": null,
"cause": {
"message": "WorkflowTask: failure executing SCHEDULED->WORKFLOW_TASK_STARTED, transition history is [CREATED->WORKFLOW_TASK_SCHEDULED]",
"source": "JavaSDK",
"stackTrace": "io.temporal.internal.statemachines.StateMachine.executeTransition(StateMachine.java:163)\nio.temporal.internal.statemachines.StateMachine.handleHistoryEvent(StateMachine.java:103)\nio.temporal.internal.statemachines.EntityStateMachineBase.handleEvent(EntityStateMachineBase.java:84)\nio.temporal.internal.statemachines.WorkflowStateMachines.handleSingleEvent(WorkflowStateMachines.java:419)\nio.temporal.internal.statemachines.WorkflowStateMachines.handleEventsBatch(WorkflowStateMachines.java:295)\nio.temporal.internal.statemachines.WorkflowStateMachines.handleEvent(WorkflowStateMachines.java:260)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.applyServerHistory(ReplayWorkflowRunTaskHandler.java:247)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.handleWorkflowTaskImpl(ReplayWorkflowRunTaskHandler.java:231)\nio.temporal.internal.replay.ReplayWorkflowRunTaskHandler.handleWorkflowTask(ReplayWorkflowRunTaskHandler.java:165)\nio.temporal.internal.replay.ReplayWorkflowTaskHandler.handleWorkflowTaskWithQuery(ReplayWorkflowTaskHandler.java:133)\nio.temporal.internal.replay.ReplayWorkflowTaskHandler.handleWorkflowTask(ReplayWorkflowTaskHandler.java:98)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handleTask(WorkflowWorker.java:413)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handle(WorkflowWorker.java:320)\nio.temporal.internal.worker.WorkflowWorker$TaskHandlerImpl.handle(WorkflowWorker.java:261)\nio.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:105)\njava.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\njava.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\njava.base/java.lang.Thread.run(Thread.java:1589)\n",
"encodedAttributes": null,
"cause": {
"message": "Operation allowed only while eventLoop is running",
"source": "JavaSDK",
"stackTrace": "io.temporal.internal.statemachines.WorkflowStateMachines.checkEventLoopExecuting(WorkflowStateMachines.java:1269)\nio.temporal.internal.statemachines.WorkflowStateMachines.randomUUID(WorkflowStateMachines.java:881)\nio.temporal.internal.replay.ReplayWorkflowContextImpl.scheduleActivityTask(ReplayWorkflowContextImpl.java:195)\nio.temporal.internal.sync.SyncWorkflowContext.executeActivityOnce(SyncWorkflowContext.java:304)\nio.temporal.internal.sync.SyncWorkflowContext.executeActivity(SyncWorkflowContext.java:278)\nio.temporal.internal.sync.ActivityStubImpl.executeAsync(ActivityStubImpl.java:59)\nio.temporal.internal.sync.ActivityStubBase.execute(ActivityStubBase.java:39)\nio.temporal.internal.sync.ActivityStubBase.execute(ActivityStubBase.java:34)\ncom.yubi.dsl.service.executor.impl.SequentialActionExecutor.execute(SequentialActionExecutor.java:75)\ncom.yubi.dsl.service.executor.impl.EventStateExecutor.executeActions(EventStateExecutor.java:90)\ncom.yubi.dsl.service.executor.impl.EventStateExecutor.executeState(EventStateExecutor.java:63)\ncom.yubi.dsl.service.DslWorkflowExecution.executeDslWorkflowFrom(DslWorkflowExecution.java:104)\ncom.yubi.dsl.service.DslWorkflowExecution.execute(DslWorkflowExecution.java:71)\nio.temporal.internal.sync.DynamicSyncWorkflowDefinition$RootWorkflowInboundCallsInterceptor.execute(DynamicSyncWorkflowDefinition.java:87)\nio.temporal.internal.sync.DynamicSyncWorkflowDefinition.execute(DynamicSyncWorkflowDefinition.java:66)\n",
"encodedAttributes": null,
"cause": null,
"applicationFailureInfo": {
"type": "java.lang.IllegalStateException",
"nonRetryable": false,
"details": null
}
},
"applicationFailureInfo": {
"type": "java.lang.RuntimeException",
"nonRetryable": false,
"details": null
}
},
"applicationFailureInfo": {
"type": "io.temporal.internal.statemachines.InternalWorkflowTaskException",
"nonRetryable": false,
"details": null
}
}
Also, StartToClose time is set to 2sec for the activities.
I am using name: ‘temporal-sdk’, version: ‘1.22.0’
and name: ‘serverlessworkflow-api’, version: ‘4.0.5.Final’