Build a workflow graph for the given workflow definition. @param workflow source workflow definition @param runtimeDag runtime dag to include all ste

Return the size of instances to terminate.

get parameter value.

get the associated workflow id.

log friendly name for logging.

static method to generate an info level {@link TimelineLogEvent}.

Utility method to assert an exception.

If there is any change event.

Static constructor.

Get short timeline message.

Get step parameter definition.

Add fields to jobParams.

Validation at initialization.

Static method to create a new ParsableLong from a long value.

get MAP type (Java Map<String, Parameter> type) param. <p>It supports nested structure and thus parameter values in the map can be another MAP type.

get evaluated parameter inside the map.

get parameter evaluated result.

Build parameter for boolean array.

Check if the condition is true. If not, throw an IllegalArgumentException. @param condition boolean condition to check @param template error message

Get job id.

Get step name. Could be absent by the user. Step id can be used when name is not provided - use StepHelper for that.

Get the specific Token.

Insert the message into the queue table. The queue table itself does not provide a deduplication key. The caller should not use the queue as a mechani

Get callback type.

Process the result set.

A wrapper class to wrap the common logic for try ... catch... @param supplier a provided wrapped function, it may throw runtime exceptions @param met

Delete the message after it is completed. @param message message to delete

Builder for currentPolicy transformed from RestartPolicy .

Notify the queue system that a message is available for processing. It will be added to the shared queue of the workers. @param message the message t

Increment a counter with a given name for class and tags. @param name metric name @param clazz class info to add it to a tag @param tags other tags t

Gets the long value of the ParsableLong. @throws NullPointerException if the ParsableLong is not a long.

logic to run when a running step is terminated by the workflow, which is entering a terminal state. It will be called by workflow engine instead of by

Gets the String value of the SignalParamValue. Caller should check that isLong() is false first.

Static method to create an owner by a username string. @param name user name string @return the owner object

add a restart node to restart path.

Get step tags.

Check if the input is not null. If null, throw a {@link NullPointerException}. @param input input object to check @param template error message templ

static method to generate a warn level {@link TimelineLogEvent}.

Static method to create a new SignalParamValue from a long value.

static method to generate a debug level {@link TimelineLogEvent}.

Merge paramsToMerge into params. @param params params @param paramsToMerge params to merge @param context Merge context

Get the metadata of the step context.

get parameter expression.

Static method to create a RunStrategy by a rule. @param rule run strategy rule in a string @return a RunStrategy object

Get the status of a specific workflow instance run. @param workflowId workflow id @param workflowInstanceId workflow instance id @param workflowRunId

Get a workflow definition for a specific version. @param workflowId id of the workflow @param version version string @return the workflow definition

Wake up a single task in a flow for a group. @param groupId group id to group flow instances @param flowReference reference is what the caller would

get parameter mode.

This run strategy logic is called at receiving a {@link RunRequest} request. As FIRST_ONLY and LAST_ONLY do not support queueing, both will directly e

Get the instance data of the latest workflow instance run for a specific workflow instance, including the summary of its step instances. @param workf

Get the instance data of a specific workflow instance run, including the summary of its step instances. @param workflowId workflow id @param instance

Build parameter for boolean array.

Initialize a new transactional {@link Connection} PreparedStatement {@link PreparedStatement} from {@link #dataSource} and pass it to {@literal statem

For testing purpose.

Get the current run strategy from maestro_workflow table.

set and wrap params.

Convert the object to the JSON string. @param value the object value @return serialized string

For testing purpose.

get evaluated STRING type (Java String type) param result. @return evaluated result.

get STRING type (Java String type) paramDefinition. @return concrete parameter definition object.

Add a new change event if it is not identical to the latest one. @param event the event to add @return true if timelineEvents is changed, otherwise f

evaluate a SEL expression. @param expr SEL expression in a string @param params Map of input parameter names and their values @return evaluated resul

Get step type.

Create a new step instance data or update all of its data. Within the transaction, it also sends the job event to the update processing queue with an