Pattern - Fail Faster, Best Efforts

Camunda 7 Topics Discussion & Questions
1

Hi All,

I have a pattern to share based on @Bernd’s recent talks re orchestration across distributed micro-services.

Problem Statement
Sometimes we want to orchestrate across a remote service as a client of the service. But what happens if that service is down, and/or beyond our control? One option is to wait until the service resumes. Another option could be to continue without the service output. A real world example could be a gecoding validation service. If the service is down, but I already have a candidate location, then why wait, I could choose to take the business risk and continue with what I have been given.

Implementation
There have been numerous threads in the forum regarding the connector architecture. One of the challenges in the connector library, is its difficult to set the socket timeout. By default, it uses the Apache HTTP Client library which tends to wait ‘forever’. Hence the first part of this pattern makes explicit use of the http client in order to set sensible (more agressive) timeouts. Thus we can set an explicit timeout strategy.

//
// Setup the request with custom timeout values.
//
def timeout = 10;
def RequestConfig config = RequestConfig.custom()
    .setConnectTimeout(timeout * 1000)
    .setConnectionRequestTimeout(3 * timeout * 1000)
    .setSocketTimeout(6 * timeout * 1000).build();
def client = HttpClientBuilder.create().setDefaultRequestConfig(config).build();

Next we can work with the retry strategy. When these service tasks use an asynchronous continuation, we can set a retry strategy. I was inspired by Bernd’s code and followed his implementation. Essentially the code interrogates if its operating within the job executor. If it is, and its on the last try, then intercept the retry mechanism to route the process down a different path. The easiest way to do this is to throw a BPMN Error (see code snippet below). I’ve seen lots of attempts to use an interrupting timer to achieve this. My conclusion is don’t mix process constructs with thread execution constructs. A process timer should not be used for interrupting threads. Its intent is to interrupt at the process level.

//
// Check to see if we are in a job executor job context. If so and we are down to the last retry,
// then take control to catch any exception, and convert to a BPMN error
//
def jobExecutorContext = Context.getJobExecutorContext();
if (jobExecutorContext!=null && jobExecutorContext.getCurrentJob()!=null) {

//
// then this is called from a Job, so if on the last retry...
//
if (jobExecutorContext.getCurrentJob().getRetries()<=1) {

    //
    // attempt the task service, if it fails, then retry is exhausted so throw a BPMN Error...
    //
    try {

        doExecute(execution);
      
    }  catch (BpmnError bpmnError) {

        //
        // Just rethrow the business BPMN Error
        //
        throw bpmnError;

    } catch (Exception ex) {

        //
        // Create a closed incident and raise a BPMN Error indicating out of retries...
        //
        def runtime = execution.getProcessEngineServices().getRuntimeService();
        def incident = runtime.createIncident("FAILED FAST", execution.getId(),"Configuration Message",ex.getMessage());
        runtime.resolveIncident(incident.getId());
        throw new BpmnError("RETRIES_EXHAUSTED_ERROR");
    }

    //
    // Otherwise the last try was successful, so just return to the engine to complete the task
    //
    return;
}

}

A reference implementation is provided in the attached model. To use, just deploy the model. There is a dependency on the Apache HTTP client library, so ensure the client library is installed in your application server. The blocking process is just to simulate a blocking API.

BlockeeIII
BlockeeIII867×712 20.1 KB

Summary
Use this pattern and techniques to more aggressively timeout on remote calls. If the call is best efforts, after the retry strategy has run, use this pattern to support best efforts and move on.

regards

Rob
BlockeeIII.bpmn (17.5 KB)

5 Likes
2

Nice pattern, thanks for sharing. If you want to avoid using BPMN error events for this, another option is to encode success or failure in process variables and then take the following actions based on that, e.g. name the activity Try to acquire geocode, then have a following exclusive gateway that takes a path depending on if the geocode is available.

1 Like
3

Thanks Thorben,

Its an interesting point. I wrestled with this as my design principle is typically business exceptions should be visible in the process model, technical exceptions should not. In this case are we dealing with a technical exception and thus I am violating my own principle? I decided that in this case, because I am making the decision not to pursue or require the service task, ie its best efforts, that this is actually a business decision. Hence in this case, it is the combination of technical failures which forces me to make the business decision which is to abandon the attempt.

Thus under this logic, it makes more sense to me to use an error event. This is not a decision I can optionally take (eg use a decision gate), its a business error condition which forces me to take this path. Hence my rationale for modelling it this way is its explicit that this is an exception path, not a discretionary decision path…

regards

Rob

4

HiRob.

Thanks for sharing - great content!

I would also model it as error event. Our best practices don’t distinguish between technical or business errors, but between technical or business reactions on errors (retry or incidents for an operator are technical reactions, fall back to plan B is a business reaction). So it is actually in-line with my personal best practices :slight_smile:

Cheers
Bernd

1 Like
5

Thanks for explaining your rationale, Rob. That makes perfect sense.

6