get runtime tags (immutable) from step runtime.

This method returns a set of iteration ids, including both iterations (no less than the checkpoint), which are in the terminal state, and the restarte

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

Get step instance view. @param workflowId workflow id @param workflowInstanceId workflow instance id @param stepId step id @return the step instance

Returns the summary for all the step iterations qualifying in the flattened view. @param workflowId @param workflowInstanceId @param workflowRunId @p

Get the step runtime states (only the last attempt) for a given workflow instance run. @param workflowId workflow id @param workflowInstanceId workfl

Get the total number of steps in runtime dag.

Get the instance of a specific workflow instance run by the workflow id and workflow uuid, including the summary of its step instances. @param workfl

Get workflow overview including version info and all instance status (partial) stats for a specific workflow. <p>As stats is directly queried from a

Task is a real task instead of a placeholder task for params or restart.

Task is a user defined task type.

Accept the visitor.

Load params from JSON file.

update step runtime summary to INTERNAL_ERROR status.

Generate md5 digest for the input string joining with @.

merge the properties changes into current properties-snapshot.

Merge tags to the tag list.

Parses the parameters within the string. @param value the string value to parse @param paramParser the function to parse the parameter @return the pa

start ExprEvaluator after construction.

Get queue id from the event.

Save a flow to DB. It might fail due to duplicate or conflict and retry will fix it. Flow DB only saves the in-processing flows. So its primary key mi

Sends output signals. @param workflowSummary the workflow summary @param stepRuntimeSummary the step runtime summary @return true if the signal is se

set payload.

Start a batch of new workflow instance runs (i.e. with run_id = 1) asynchronous. It first created workflow instances in DB and then send a job event t

Return true if done, false if async.

Terminate the execution without sync.

Convert a DSL WorkflowDefinition to a WorkflowCreateRequest. @param dslWorkflowDef the DSL workflow definition @return the WorkflowCreateRequest for

Unregister a step uuid from the uuids for a given concurrencyId. If failed, it throws a MaestroRetryableError.

Update some info, e.g. adding new restart node to the path.

Update runtime state within runtime summary.

Create or Update a job template. @param createRequest job template create request

@return token image as String

Add fields to extraInfo.

Add transition info from dag field to jobs if not already present. @param jobs a list jobs @param dag the dag info

get BOOLEAN_ARRAY type (Java boolean[] type) paramDefinition. @return concrete parameter definition object.

get BOOLEAN type (Java Boolean type) paramDefinition. @return concrete parameter definition object.

Get Retry type artifact. @return concrete artifact object.

By passes all pending step dependencies by changing their status from PENDING to SKIPPED. It also records the user and timestamp info in the {@link co

Construct next time trigger execution message from existing message and executed time triggers. @param timeTriggerExecution the existing time trigger

Convert a list of DSL Jobs to a list of common model Steps. @param jobs the list of DSL jobs @return list of Steps

ParamMode creator.

static creator.

static method to create a restart action.

static method to create a termination action.

return a random uuid as a message key. todo make it more readable than uuid.

In NOT_CREATED case, the task actor might run while the parent is not. But the next isRunning check will discover it as it also checks the parent stat

Best effort to extend the ownership of the message. If the message is not owned by this worker, it returns null. If failed to extend the ownership, it