Get the terminal step status for a termination action (KILL, STOP, SKIP). Note that the termination action can come from the upstream. If it is from t

Get Timezone for trigger.

It heartbeats to keep the ownership of the flow group. It also detects if the ownership is lost unexpectedly. It returns the flag (if the ownership is

Converts {@link Duration} to human-readable string. <p>Example output: <ul> <li>5h <li>7h 15m <li>6h 50m 15s <li>2h 5s <li>48h </ul> Note

Initialize rollup with "base rollup" to aggregate rollup across runs. @param foreachOverview foreach step overview for a current run @param prevForea

Returns true if the ParsableLong is a long.

check if the latest event in the list matches the input event.

Static method to create a RuntimeOverview.

remove all already-released step tag permit records. @return the uuids of deleted records.

Resume a maestro flow by filling data into it. @param flow the flow object to be filled with tasks, etc.

Resume a paused step instance attempt.Users can choose to resume specific attempt even when breakpoint is set. @param workflowId workflow id for the

Utility method to retrieve step runtime summary from the key-value data. @param data all data in a map @return a step summary object

sync the pending updates to maestro step instance db and also publish notifications. <p>It never throws an exception and step runtime state machine w

Send terminate events for all running workflow instances with a batch limit. @param workflowId workflow id @param limit size limit for each event @pa

Convert the string to a numeric number and return it if yes.

convert an action to timeline event.

Update some info only for restart case, e.g. remove last restart node from the path.

Add an instance uuid into the uuids for a given concurrencyId with depth. It will check if either instance uuid set or step uuids reach the limit. If

Add a lock for the given queue id if not exists. It is idempotent. @param queueId queue id @return the number of rows affected (0 or 1)

Add a workflow run (instance id, run id, uuid) to the job event.

Add a signal instance to db. @param conn db connection @param instanceId signal instance id for deduplication @param name signal name @param instance

subscribe to the workflow signal trigger including signal names in the trigger. It also saves the current latest signal sequence ids as the checkpoint

get DynamicOutput type artifact. @return concrete artifact object.

get STRING_ARRAY type (Java String[] type) paramDefinition. @return concrete parameter definition object.

get WhileArtifact type artifact. @return concrete artifact object.

Check if all the chars in a string are whitespace characters. @param s a string to check @return return true if all the chars in a string are whitesp

Get an unclaimed flow group and then claim it. Note that each flow actor will resume to load data from maestro workflow and step instances to rebuild

It computes the stepIds included/reachable in the current runtime DAG of the workflow instance run.

static creator.

It derives the runtime tags with their permits based on workflow level and step level step_concurrency and instance_step_concurrency when either enabl

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

Mark the execution id for idempotency.

check if there is any step in NOT_CREATED status.

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

Get the attributes. @return the attributes of the tag.

get parameter expression.

Get the literal value derived from a parameter's value field.

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

Get the current restart workflow instance id.

Get stackTrace with maximum number of lines returned. @param throwable throwable error @param maxLines max number @return bounded stacktrace string

Get a single step iteration for given iteration rank. @param workflowId id of workflow this step belongs to. @param workflowInstanceId id of workflow

Get the latest workflow instance run for a specific workflow id between an instance id range. @param workflowId workflow id @param startInstanceId wo

Mark tag permit as removed. It will be deleted async by the tag permit task. @param tag tag name

Mark step tag permit status to be acquired. @param uuid step uuid @return whether there is an update on a record

Match signal params with non-empty paramMatch list since a checkpoint. @param conn db connection @param signalMatch signal matching request with non-

Get matched signal sequence id for the given signal step dependency. It is currently based on polling and can support push if needed. The query only n

Create Jackson object mapper with maestro needed features.

Processes the message of type T. After processing, it is optionally to return a MaestroJobEvent for the next processing, which might be a different ty

Run monitoring task.

Remove all tag permits marked as removed. @param limit maximum number of records to remove @return the tags of deleted tag permits

set params.

Set job transition info (successors only).

Transform it to a maestro event.

transform RunResponse to WorkflowStartResponse.

Save a flow group to DB. It might fail due to duplicate or conflict and retry will fix it. It's caller's responsibility to retry and find the right no

Try to unblock failed workflow instance by set its status to FAILED_1.

Update a running task in the running task map. RunningTasks map only keeps the latest attempt per task ref name. It will contain the dummy tasks. As r

Add a signal instance based on the signal create request.

get LONG_ARRAY type (Java long[] type) paramDefinition. @return concrete parameter definition object.

Build merged parameter definition from new and previous parameter definition. <p>An example sequence is <p> <ol> <li>For each in Workflow defined

Rollup base consists of subworkflow and foreach step rollups from previous runs, and regular step rollups from previous runs. @param instance workflo

Update some info to start a new run.

Ignore failure mode only if KILL action is from upstream or KILL action is a workflow level action. In either case, no need to apply failure mode afte

Delete all workflow data for a given workflow id or unique internal id with a timeout in nanos. @param workflowId workflow id @param internalId inter