Evaluate a given parameter using available workflow params. @param workflowId workflow id @param workflowParams available workflow parameters @param

Builder for initiator.

By default, the event is ordered by its timestamp.

Merge parameters in step definition and step runtime. <p>It includes all runtime params from step definition and step runtime injection and condition

Get status code. @return status code of the exception

Get step instance from DB for a given step instance attempt.

set parameter evaluated result.

Start a maestro flow. @param groupId group id to group flow instances @param flowId the flow id, which must be unique, e.g. a random uuid @param flow

Convert a parameter definition to an un-evaluated parameter instance.

Get the step action. If failed to get the action, treat it as no action in DB. The caller is expected to check the action again.

Upsert workflow trigger subscription to external service. @param workflow workflow includes triggers @param current current active trigger uuids @par

get evaluated LONG type (Java Long type) param result. @return evaluated result.

Calculate executions for time triggers. @param timeTriggerWithWatermarks an array of time triggers with watermark @param workflowId used by fuzzy cro

Computes aggregated view representation based on passed instance. Also computes aggregated status. @param workflowInstance Aggregate from run 1 to pa

Get the parent of the current workflow instance.

get validation rule.

Get job transition info (successors only).

Static method to create a RuntimeOverview.

set and wrap step params.

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

Add given iteration info including its rollup overview to the foreach step overview.

Dequeue workflow instances considering the current run strategy. It won't update the instance state but will always deterministically send out the run

Customized step execution logic. <p>While the step status is RUNNING, the code in execute() will be called periodically with a preset polling interva

This is thread safe and can be called by flow's task actors directly.

Below are helper methods for tests to create sample WorkflowInstance and StepInstance.

Get all step attempts paused via breakpoint identifier. @param workflowId workflowId identifier for the breakpoint. @param version workflow version i

This method returns a child node. The children are numbered from zero, left to right.

Translate function. @param definition source definition data @return translated data

Make a full copy of the task. It is thread safe. @param task task to clone @return cloned task object

Get the identity of the step context.

set predecessors.

Add a finished task to the finished task map. FinishedTasks map only keeps the latest attempt per task ref name. It might contain the dummy tasks. @p

Gets the int value of the ParsableLong.

get LONG type (Java Long type) paramDefinition. @return concrete parameter definition object.

Build a DAG including all step ids and their transitional relations for the given workflow definition and optional start step ids and end step ids. @

Parse an input param's literal value with the string interpolation support.

Used to get if there is any flow instance with this flow keys.

true if the parameter is defined as a literal; false if it is a sel expression.

Callback logic to run when a flow is finalized. @param flow flow for the callback

Starts the maestro workflow. @param workflowId the workflow id @param version the workflow version @param workflowTriggerUuid the workflow trigger uu

get evaluated DOUBLE_ARRAY type (Java double[] type) param result. @return evaluated result.

Decide if step should transition to the PAUSE state. Also create paused step attempt. Step can only be paused if a breakpoint is created matching the

Create a workflow instance based on the workflow info, e.g. definition, run request, etc. @param workflowDef versioned workflow definition @param int

Get step breakpoints for step identifiers. It supports layered look up. For e.g. is user has asked to provide all breakpoints for specific step attemp

Read a character.

Restart a step. Will create a new step attempt if the workflow instance is still not in a terminal state, otherwise, create a new workflow instance ru

set parameter evaluation time.

Get all paths. @param translator translator from step to type T. @param <T> path node type. @return all paths.

Encode a long or string signal value into a string, which preserves the original ordering. String type will prepend '#' to the original value as the f

the depth from the root to this instance.

Get step id.

Helper method to get the closest non-inline ancestor info.

Stop all current running workflow instances for the given workflow id. @param workflowId workflow id @return the final timeline log message

build action with an enum object.

Computes workflow instance status from the aggregated view. @param currentInstance instance for which we calculate the aggregated view @param aggrega

Translate compressed stepOverview into human-readable format, key is step id and value is step runtime state. Only takes into account steps from step

Delete a signal trigger. @param workflowId workflow id @param triggerUuid signal trigger uuid

Create a placeholder parameter with derived param type based on the evaluated result.

Execute an HTTP request. @param request the HTTP request to execute @return the HTTP response @throws IOException – if an I/O error occurs when sendi

Get reference parameter names from an input param with the string interpolation support.

get parameter type.

Check if a DAG with all terminate state steps is actually done. @param runtimeDag the runtime dag with step transitions @param idStatusMap map from s

refresh details of foreach step.

set and wrap step run params.

Check if a step should be resumed. @param workflowId workflow id for the paused step. @param version workflow version for the paused step. @param ins

Cleanup parameters, remove unused optional params.

Enqueue a job event for the cases, there is no need for a transaction. If failed, it throws an exception. It requires the caller to retry if there is

Util helper method to return a flattened list of instance ids derived from intervals.

Get rollups of the latest runs of foreach inline workflow instances for a given list of iteration ids. @param workflowId foreach inline workflow id @