Get the latest run's foreach step artifact from DB for a given instance.

Get the loop params names and values for the leaf inline workflow instance, root non-inline workflow definition and the initiator information. @param

Get merged rollup info from complete iterations and running iteration aggregated from run1 to current run.

helper method to get the root.

Helper method to create Step output Params. @param outputs definition of step output @return a map of output in map param format

Get stepId to runId map for loop (foreach or while) and subworkflow steps from previous runs. @param instance current run's workflow instance @return

Get time from the timestamp field if present. @param rs The result set. @param field Timestamp field. @return The timestamp value in long if not null

Get timeline event type.

utility method to get real maestro task mapping from internal task data.

get parameter value.

Get the properties snapshot for a given workflow id and snapshot version.

Postconstruct initialization for DefaultParamManager.

Static method to initialize a {@link TerminateThenRunJobEvent}.

Initializes step rollup with "base rollup". "Base rollup" consists of rollup of steps completed as parts of previous runs. It's calculated by taking a

Create a new brand new empty group. @param groupId new flow group id @param address new flow group owner address @return the added flow group

Check if there is pending deletion for a given workflow id.

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

Checks whether the step's output data marks a failed step as non-retryable by the system. @param runtimeSummary step runtime summary used to locate t

Mark and load a batch of tag permits to be synced, up to the given limit. @param limit maximum number of records to mark and load @return list of tag

Marks every still-pending dependency as {@link StepDependencyMatchStatus#CANCELED}, used when the owning step reaches a terminal state and the depende

Mark the current transaction as SERIALIZABLE isolation level. @param conn the connection @throws SQLException sql exception

Override param type if needed. This is mainly used to help data mode change for backward compatibility. @param params params to be overridden

Merge output params into parameter map.

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

Parse the parameterized parsable long. @param paramParser the function to parse the parameter @param elseOperator the additional function to apply if

preprocessing the parameters in instances by validating result and setting name.

build reason with arguments.

unique identifier as the actor reference.

Retrieve the step runtime state from a map. @param data data contains step runtime summary, which has a status field. @return status of the step inst

Update the statistics with the specified amount in milliseconds. @param name metric name @param duration duration to update @param clazz class info t

Create one of WorkflowChangeEvent types from {@link WorkflowVersionUpdateJobEvent}. @param clusterName workflow definition cluster name @return a wor

static method to create TriggerUuids from a workflow.

Reinitialise.

Add an attribute to tag attributes. @param key of the attributes, for example "creator". @param attribute is the value of the attributes, for example

This method provides a way to implement adding extra tasks (i.e. dummy tasks for param) to the flow. It also supports to add some data to the input of

get DOUBLE type (Java Double type) paramDefinition. @return concrete parameter definition object.

best effort operations without retry support.

Utility method to convert an object in the field of the data to a given class type. @param data map of all data @param fieldName map key to get the s

Create a new param definition from copy and passed arguments.

Helper method to create {@link SignalInstanceSource}. @param summary workflow summary @param runtimeSummary step runtime summary @return the signal i

Static method to create an WorkflowDefinitionPendingEvent from WorkflowDefinition. @param definition workflow definition from API @return a workflow

Static method to create an InstanceActionJobEvent for a step action. @param stepInstance step instance @param action step action @return a step insta

Static method to create StepInstancePendingRecord.

Inverse of {@link #encodeByLength(String)}: strips the leading length-prefix character.

Derive the aggregated workflow instance status. Also, if needed, set the run status in the pending overview.

Encode a positive long value into a compact base62 string using some special algorithm. For the case (e.g. range key) if the string must be preserving

Insert the message into the queue table. It only ensures the message is inserted once within the same transaction. It's caller's responsibility to ens

Enrich the current workflow timeline by adding additional events from workflow instance for external API.

Enrich workflow definition object with extras and add params, next run date and other enriched fields. @param workflowDefinition workflow definition

Populate common base step fields from a DSL job. @param step the target Step @param baseJob the source base job

static method to create a {@link WorkflowInstanceActionResponse} from a {@link WorkflowInstance} and its completed status and event log message.

Get all step attempts from DB for a given a workflow instance run.

Gets the attemptSequence indicating the sequence of runId-stepAttemptId... from the root non-inline workflow to the immediate inline workflow. For exa

Return dry run parameter defaults. @return default dry run params

get parameter evaluation time.

Get fields from extraInfo.

extraInfo includes optional extra information associated with the tag permit.

Return HTTP Status code. @return HTTP response status code

return step runtime identity info.

Get the latest run's while step artifact from DB for a given instance.

Calculate list of rollups for subworkflow and foreach steps from previous runs. @param workflowId workflow id @param workflowInstanceId workflow inst

Static util method to extract the second to the last node from the restart path.

Returns the keyset of the underlying evaluatedResult maps. @return set of param names