Finishes a {@link MaestroTracingContext} with an exception.

Set a gauge with a given name for class and tags. @param name metric name @param value value to set @param clazz class info to add it to a tag @param

Get step ids to its instances mapping from DB for ancestor run ids of a workflow instance run, i.e. run_id less than the current run_id. It only consi

Get all the step dependencies (only the last attempt) for a given workflow instance run. @param workflowId workflow id @param workflowInstanceId work

Each step instance is queried as a point query, every N queries are combined into one using a UNION. @param workflowId workflow id @param workflowIns

Generate a parameter for completedByTs.

get database config.

get database source.

Get step description.

Get the parameter's evaluate results as raw string from the step in a foreach. Note that This method accepts input from users and PreparedStatement is

Fetch an existing job template definition. @param jobType job type @param version version value, e.g. "default" @return the job template

Get the latest status of a workflow instance. @param workflowId workflow id @param workflowInstanceId workflow instance id

Get next retry delay for platform errors.

Get next retry delay for timeout errors.

Get next retry delay for user errors.

Get the signal's payload. @return the un-indexed payload of signal request.

Gets current run strategy or default.

Returns a {@link PaginationResult} of {@link StepIteration}s for the given step at particular run.

Get subscribed triggers for a given signal instance. @param signalInstance signal instance @return a list of matched signal triggers

Get maestro event type.

Get initiator type info.

Returns workflow id if workflow name is missing and was not provided by the user. @return workflow name

Returns true if the SignalParamValue is a long.

check if this run request is a system initiated run.

Kill/fail the given non-terminal workflow instance's latest in-progress run. It is possible to kill a given instance multiple times due to the process

Load step tag permit records starting from the given cursor (exclusive) with the given limit. @param cursor the last uuid from previous batch, pass n

Mark and load a batch of step tag permits to be synced, up to the given limit. @param maxSeqNum the maximum known seq_num @param limit maximum number

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

Remove an instance uuid from the uuids for a given concurrencyId with depth. If failed, it throws a MaestroRetryableError.

Remove an existing job type. @param jobType job type @param version version value, e.g. "default"

Run a batch of foreach workflow instances for a given workflow and version. The request list has already been sized by insertBatchLimit in StepRuntime

Run business logic using internal workers instead of directly over virtual threads.

Save output data to database. It also replaces values with placeholders in following cases: <li>- replace values with placeholders when identical to e

Pre-destroy to shut down flow executors.

Stop the given non-terminal workflow instance's latest in-progress run. It is possible to stop a given instance multiple times due to the processing d

Add a list of workflow signal triggers and subscribe the future signal announcements. @param conn db connection to provide transaction support @param

transform RunResponse to StepInstanceRestartResponse.

Creates brave's {@link TraceContext} from the current {@link MaestroTracingContext} object.

transform RunResponse to WorkflowInstanceRestartResponse.

Update step instance table with runtime updates. Within the transaction, it also sends the job event to the notification queue for external notificati

validate the identity.

Add signal params into the table.

best effort operations without retry support.

get DEFAULT type artifact. @return concrete artifact object.

Cast timeline to {@link TimelineDetailsEvent} if possible.

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

Bypasses the step dependencies.

Claim the expired ownership of a flow group. Note that it might claim the same expired group again but will have a different generation. @param addre

Check if parameter is defined.

static PropertiesSnapshot creator.

static creator.

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

Return the grouping key based on workflow instance.

It derives the actual instance_step_concurrency based on what users set and system defaults. It needs to consider all the cases and also set the right

check if there is any step in NOT_CREATED status.

Generate Kubernetes command for workflow step. Extract data from parameters. @param context Kubernetes step context @return a Kubernetes command obje

utility method to get internal task output data mapping from internal flow data.

Get the parameter's type from the step in a foreach. If null, it throws an exception. Note that This method accepts input from users and PreparedState

Get the log of a finished kubernetes job. @param jobId Job ID. @return Job log.

Get the job output including output params and output signals of a finished kubernetes job in the string format. The caller is responsible to take car