Return output data {@link OutputData} for specific step instance. @param externalJobId External Job ID such as a container instance id @param jobType

Operates the tracing context based on step instance status. An exception can be included to annotate the failure.

Return the number of children the node has.

Activate a specific workflow version if feasible. It won't change the owner info. @param workflowId workflow id @param version workflow version to ac

Add a step into the summary.

get evaluated INT_ARRAY type (Java long[] type) param result. @return evaluated result.

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

get evaluated STRING_ARRAY type (Java String[] type) param result. @return evaluated result.

get evaluated STRING_MAP type (Java Map<String, String> type) param result. @return evaluated result.

Evaluate workflow parameters. @param workflowParams workflow parameters to be evaluated @param workflowId workflow id

Build instance wrapper for the sel evaluation. @param workflowSummary workflow summary @param stepRuntimeSummary step runtime summary @return the ins

Get default params for Step type. @param stepType step type @return optional type to default param map

Return default parameters to be injected. @return default step params

Get step instance identity.

Get step subtype.

true if the parameter is evaluated.

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

update step runtime summary to terminal status.

Recursively restart a workflow instance by reversely tracing up along the ancestor chain. If there is a still-running workflow instance along the ance

Collector to create a {@link LinkedHashMap} object.

static method to generate a trace level {@link TimelineLogEvent}.

get evaluated BOOLEAN_ARRAY type (Java boolean[] type) param result. @return evaluated result.

Return UUID generated by the input string. If null, return a random one.

Create a workflow summary for the workflow instance. @param instance the workflow instance to be used to build summary @return the workflow summary

Generate Papermill properties for notebooks executions. @return the generated papermill command object

extraInfo includes optional extra information, e.g. source_definition, api_version, dsl_client_hostname, dsl_client_version, dsl_lang, dsl_source, etc

Get foreach run iteration instance status stats for a given workflow id, run_id, across all its iterations/instances larger than the current checkpoin

Get step timeout in seconds.

Get step transition info.

Create a paused step attempt due to a breakpoint. This is created when a step checks for paused state - {@link MaestroTask} @param workflowId workflo

determine if the given workflow id is for an inline workflow.

Accept the visitor.

Rebuild all transient data for a given flow. It returns a flag to indicate if the prepare task should be called again to finish resuming. @param flow

Batch scanner for workflow Definition. @param workflowId workflow id @param versionId version id @param limit limit @return a list of workflow defini

Create merge context for step params.

Terminate queued workflow instances run if possible. Otherwise, do nothing. @param workflowId workflow id to terminate @param limit the size limit to

Insert or update a job template. @param jobTemplate the job template to upsert

aggregate rollup overview into this and return itself.

get ForeachArtifact type artifact. @return concrete artifact object.

Check if the workflow is completed by checking maestro step status. @param realTaskMap task map to include only real tasks for maestro step @param su

utility method to compute workflow runtime overview from task data.

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

get the evaluated result from a parameter inside the map.

Get iterations that are going to be run the current run. We do that by getting the difference between initialized details in the current run and prev

Get run status of this workflow instance run.

get tags.

Get timeline event timestamp.

Insert a tag permit status record with the given uuid, with initial status of 0 (unknown). @param uuid step uuid

merge step runtime updates to the runtime summary.

Parse a list of dsl transition strings into a Maestro StepTransition object. @param transitionList list of dsl transition strings @return parsed Step

Mark tag permit status to be released. It will be removed async by the tag permit task. @param uuid step uuid

Convert an object (might be double[], BigDecimal[], List, etc.) into a BigDecimal array for a param with a given name. @param name name for identific

Merge back output parameters updated by step into params space along with validation.

Create merge context for workflow params.

get evaluated DOUBLE type (Java Double type) param result. @return evaluated result.

Check the status of a kubernetes job. @param jobId Job ID. @return Kubernetes job result.

Get workflow instance identity.

Get internal param mode.

Resolves the leaf step instance reference from the encoded breadcrumbs. The leaf instance id is the last segment of the iterationRank, and the leaf ru

Get the current restart step id.

Match signal dependency with non-empty paramMatch list. @param signalMatch signal dependency with non-empty paramMatch list @return signal sequence i