io.nflow.engine.workflow.definition

Class WorkflowSettings

java.lang.Object

io.nflow.engine.model.ModelObject

io.nflow.engine.workflow.definition.WorkflowSettings

public class WorkflowSettings
extends ModelObject

Configuration for the workflow execution.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkflowSettings.Builder Builder for workflow settings.

Field Summary

Fields

Modifier and Type	Field and Description
int	immediateTransitionDelay Immediate transition delay.
int	maxErrorTransitionDelay Maximum delay on execution retry after an error.
int	maxRetries Maximum retry attempts.
int	maxSubsequentStateExecutions Maximum number of subsequent state executions before forcing a short transition delay.
Map<WorkflowState,Integer>	maxSubsequentStateExecutionsPerState Maximum number of subsequent state executions before forcing a short transition delay, per state.
int	minErrorTransitionDelay Minimum delay on execution retry after an error.
int	shortTransitionDelay Length of forced delay to break execution of a step that is considered to be busy looping.

Method Summary

Modifier and Type	Method and Description
protected long	calculateBinaryBackoffDelay(int retryCount, long minDelay, long maxDelay) Return activation delay based on retry attempt number.
org.joda.time.DateTime	getErrorTransitionActivation(int retryCount) Return next activation time after error.
int	getMaxSubsequentStateExecutions(WorkflowState state) Return the maximum number of subsequent state executions before forcing a short transition delay.
org.joda.time.DateTime	getShortTransitionActivation() Return the delay before next activation after detecting a busy loop.

Methods inherited from class io.nflow.engine.model.ModelObject

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

minErrorTransitionDelay

public final int minErrorTransitionDelay

Minimum delay on execution retry after an error. Unit is milliseconds.

maxErrorTransitionDelay

public final int maxErrorTransitionDelay

Maximum delay on execution retry after an error. Unit is milliseconds.

shortTransitionDelay

public final int shortTransitionDelay

Length of forced delay to break execution of a step that is considered to be busy looping. Unit is milliseconds.

immediateTransitionDelay

public final int immediateTransitionDelay

Immediate transition delay.

maxRetries

public final int maxRetries

Maximum retry attempts.

maxSubsequentStateExecutions

public final int maxSubsequentStateExecutions

Maximum number of subsequent state executions before forcing a short transition delay.

maxSubsequentStateExecutionsPerState

public final Map<WorkflowState,Integer> maxSubsequentStateExecutionsPerState

Maximum number of subsequent state executions before forcing a short transition delay, per state.

Method Detail

getErrorTransitionActivation

public org.joda.time.DateTime getErrorTransitionActivation(int retryCount)

Return next activation time after error.

Parameters:

retryCount - Number of retry attemps.

Returns:

Next activation time.

calculateBinaryBackoffDelay

protected long calculateBinaryBackoffDelay(int retryCount,
                                           long minDelay,
                                           long maxDelay)

Return activation delay based on retry attempt number.

Parameters:

retryCount - Retry attempt number.

minDelay - Minimum retry delay.

maxDelay - Maximum retry delay.

Returns:

Delay in milliseconds.

getShortTransitionActivation

public org.joda.time.DateTime getShortTransitionActivation()

Return the delay before next activation after detecting a busy loop.

Returns:

The delay in milliseconds.

getMaxSubsequentStateExecutions

public int getMaxSubsequentStateExecutions(WorkflowState state)

Return the maximum number of subsequent state executions before forcing a short transition delay.

Parameters:

state - The state for which the limit is checked.

Returns:

The maximum number of subsequent state executions.