Clear the current param extension.

static creator.

Get Parameter source.

create a new task attempt based on latest task info. @param def task def @param inline flag to indicate if the task is actually run by the flow actor

Schedule an action for the future. @param action action to schedule @param delayInMillis delay to wait @return the future object

Insert step breakpoint. @param workflowId workflow id for the breakpoint. @param version workflow version for the breakpoint. Special value to denote

static method to create a {@link RunResponse} from a {@link WorkflowInstance} and its state.

Return created workflow definition {@link WorkflowDefinition} posted by users. @param workflowDef WorkflowDefinition with incomplete data. Filling it

Update workflow instance for workflow start and restart cases. It does the param evaluation, string interpolation for some fields. It won't update wor

Get signal step outputs, e.g. signal outputs.

Push a signal instance. @param signalInstance the signal instance to push

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

Initialize a new transactional {@link Connection} from {@link #dataSource} and pass it to {@literal function}. It includes a retry mechanism for clien

Terminate queued workflow instance run if feasible. Otherwise, do nothing. @param instance workflow instance @param status status to mark @param reas

Add a list of new change events if they are not identical to the latest one. @param events events to add @return true if timelineEvents is changed, o

static method to generate a {@link TimelineStatusEvent}.

extract properties info.

Convert a parameter to a parameter definition, where its value is set by evaluatedResult and other param attributes (e.g. param mode) will be copied.

Return the value or the default one if the value is null. @param value input value @param defaultValue default value to return if the value is null @

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

Delete all created data for a given dag tree with a given concurrencyId.

Static method to read a JSON to an object. It throws a non retryable error if the processing is failed.

Get a specific signal instance. @param signalName the step runtime summary @param signalId the signal id @return the corresponding signal instance

Logic to run when starting the maestro step runtime. <p>With the at-least-once guarantee, this method will run at the beginning of the life cycle of

Evaluate a step parameter, including sel or string interpolation. @param allStepOutputData parameter definitions from all step definitions in the wor

Get signal step dependencies definition.

check if this run request is a fresh run (i.e. not a restart).

get evaluated BOOLEAN type (Java Boolean type) param result. @return evaluated result.

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

Static method to create a Tag object by its tag name. @param name tag name string @return a Tag object

create {@link TimelineDetailsEvent} from {@link Details}.

Generate merged workflow parameters. @param instance workflow instance including run properties @param request run request @return a map of parameter

Return job template schema {@link JobTemplate} for a job type and its version. @param jobType job template id, which is always same as step sub_type

get parameter name.

Get a maestro event type.

Gets the iteration rank indicating the sequence of iteration1-iteration2... from the first inline workflow to the last inline workflow. For example, i

start up.

This method tells the node to add its argument to the node's list of children.

build message with arguments.

Process a maestro job event by calling the actual job event processing based on the event type. @param jobEvent maestro job event to process

Send a Maestro event to external topics. @param event Maestro event to send

build runParams.

Create a list of new workflow instance runs (with run_id already set) in DB. It will skip if an instance id is duplicated and fail if the instance uui

Apply operations on the prepared statement.

Get a workflow instance for a specific run. @param workflowId id of the workflow @param instanceId instance id @param runId run id @return the workfl

Static creator for JSON.

Insert the message into the queue table to replace an existing message. @param message the current message to be replaced @param jobEvent the new mes

Get next retry delay based on error and configured retry policy. @param status the step instance status @return the next retry delay in secs.

set parameter name.

get parameter type.

Scans the stepIterations. @param workflowId @param workflowInstanceId @param workflowRunId @param stepId @param iterationRank @param limit @return

Add an event to the timeline if not identical to the latest event.

Get value for a key from the map, which might be null. If absent, return default values.

increment corresponding retry count based on status.

Return true if the collection is null or empty.

Directly restart a step without going to its ancestors.

setter with a validation check.

Update the workflow properties posted by users. <p>Note: if no wf exists, cannot push properties. @param workflowId workflow id @param props propert

Get a timeline info with initiator identity.

Parse the ParsableLong value (default in seconds) for timeout and returns duration in milliseconds.

Load runtime parameters based on the step type and its subtype. @return a collection of runtime generated parameters to inject @param workflowSummary