topic Re: Running workflows asynchronously in Alfresco Archive

Running workflows asynchronously

pmesmeur — Tue, 16 Jun 2015 11:49:17 GMT

Hello,I would like to use Activiti to run workflows that possibly contain long service tasks (that may run for more than one minute). Such workflows would be called viarocessEngine.getRuntimeService().startProcessInstanceByKey(…);‍‍‍However, the method startProcessInstanceByKey() will return/leave

Re: Running workflows asynchronously

pmesmeur — Tue, 16 Jun 2015 11:55:46 GMT

I my 3rd point, a null timer would certainly solve my problem as well as a "dummy" empty async service task

Re: Running workflows asynchronously

pmsevestre — Wed, 17 Jun 2015 04:51:43 GMT

Instead of adding a dummy async task, what you can do is to create a custom parser handler that forces all "long running tasks" to be asynchronous.

That leads to the problem of how would you inform the parser when a task is "long" or not. One option is to elect one of the activities types for this specific purpose. The script task or system task are good candidates, since they´re the ones that usually contain custom logic that can take longer to execute.

Be aware though that this kind of implicit behaviour must be fully understood by the person who is designing the BPMN process, since it changes the transaction contract associated with the execution of consecutive activities.

Re: Running workflows asynchronously

martin_grofcik — Wed, 17 Jun 2015 06:23:55 GMT

Hi Philippe,

to answer your questions:

Is the a difference regarding the database between sync and async task?

Yes there is. (Async = create job and execute it)

If yes, do you think it has a high impact on the performance?

The performance impact is minimal with AsyncExecutor. DefaultJobExecutor performance impact is not huge too. (it really depends on your requirements)

Possible issue of your proposal is that "long" service call is executed in transaction too. (transaction can timeout during the service call).
Another issue is that one thread is blocked for +/- one minute during the service call.

I would prefer another approach.

Just call the service and get response from the service that request was accepted. It should be fast.
When service finishes its work it could send the signal (message) to the activiti engine to continue in the process execution.

Regards
Martin

Re: Running workflows asynchronously

pmesmeur — Wed, 17 Jun 2015 07:11:52 GMT

Thank you Martin for this pertinent answer. I would like to clarify what you propose in order to be sure that I correctly get what you mean

As I understand, you propose that, for processing a long running service, I create a dedicated thread and temporarily suspend the execution of my workflow. In the new thread I do the (long) work and once it is completed, I send a message to the activiti engine in order it restarts the execution of the workflow. So I don't rely on async property anymore. Am I right?

If yes, I would like to know the cleaner way to suspend the service task? Has my long-running-service to extend ActivityBehavior instead of JavaDelegate? If yes once again, I'll have to make the BlueprintELResolver able to work with ActivityBehavior (not only with JavaDelegate)

Regards,
Philippe

Re: Running workflows asynchronously

pmesmeur — Wed, 17 Jun 2015 07:12:50 GMT

Thank you pmsevestre for your consideration.

"That leads to the problem of how would you inform the parser when a task is long or not": this is a point I already considered and which is easily doable, at least in the context of my project. To be short, in the function executeParse() of my own ServiceTaskParseHandler, I have this information:

<java>
public class MyOwnServiceTaskParseHandler extends ServiceTaskParseHandler {

    @Override
    protected void executeParse(BpmnParse bpmnParse, ServiceTask serviceTask) {
        ….
        boolean isAsync = hasTaskToBeAsync(serviceTask);
        bpmnParse.getCurrentActivity().setAsync(isAsync);
        …
    }
}
</java>

Doing that, I can easily make my long running tasks being async so startProcessInstanceByKey() will now be async, i.e. it will not wait for the end of my long running task before returning

Now, my main question the impact of making workflows "not having long running tasks" asynchronous too, in order they are treated consistently with workflows "having long running tasks"

"Be aware though that this kind of implicit behaviour must be fully understood by the person who is designing the BPMN process, since it changes the transaction contract associated with the execution of consecutive activities": one of my objectives is that the BPMN process designer is not impacted at all with any implementation detail. Can you please tell me more about the changes regarding "transaction contract associated with the execution of consecutive activities"?

One again, thank you very much

Philippe

Re: Running workflows asynchronously

trademak — Wed, 17 Jun 2015 10:34:40 GMT

Hi Philippe,

When you make any service / script task asynchronous, this means a job will be created in the Activiti database and it will be execute asynchronously in a different transaction. So if the task fails it will not rollback to previous state in the process instance, but it will retry the job.

Best regards,

Re: Running workflows asynchronously

pmesmeur — Wed, 24 Jun 2015 09:14:44 GMT

Now I'm convinced that I have to forget the async parameter, so I am studying another solution based on what I read on http://forums.activiti.org/content/java-service-task-passivate-wout-receive-task

First of all, my services do not implement JavaDelegate but ActivityBehavior (in fact they extend AbstractBpmnActivityBehavior)
In the "void execute(ActivityExecution execution)" method, two possibilities:

The service is not a long running task

The service is a long running task

This solution seems to work fine. What do you think of it? Do you find any cons? Is it safer in a transnational point of view?

Best regards,
Philippe

Re: Running workflows asynchronously

trademak — Wed, 24 Jun 2015 20:11:09 GMT

Hi Philippe,

I don't see an issue with this approach. Should work fine if this is what you are looking for.

Best regards,

Re: Running workflows asynchronously

pmesmeur — Thu, 25 Jun 2015 07:36:03 GMT

Hi,

now that I have an acceptable solution to launch my long-running task asynchronously in a dedicated thread, I want - when an exception or a timeout occurs - to forward it to the activiti engine.

According to you, what is the best way a do this? I tried to do
[java]
processEngine.getRuntimeService().signalEventReceived("timeout", execution.getId());
[/java]
but unfortunately I did not succeed to subscribe pro grammatically to "timeout" signal

Thank you for your precious help
Philippe

Re: Running workflows asynchronously

jbarrez — Tue, 30 Jun 2015 19:36:48 GMT

"but unfortunately I did not succeed to subscribe pro grammatically to "timeout" signal"

What do you mean here? Of course, the signal needs to be modeled in the process, but is that a problem?

Re: Running workflows asynchronously

pmesmeur — Tue, 30 Jun 2015 21:19:00 GMT

I was trying obscure things. I won't spent time to explain clearly what I wanted to do, because now that I have a deeper view, I realize that it was not clear at all 😉

My main need was to forward an exception from my Service running in a dedicated thread to the engine. After I wrote my last comment, I found the following page… and it seems that you already know the rest of the story 😉

Philippe