Run string interpolation on input using the evaluated params for attribute fields, e.g. tct, timeout, etc.

Prepare the prepared statement.

preprocessing the parameters in definition by validating value and setting name.

Release the owned messages in the queue with the best effort. If failed, it will let the message expire. @param queueId queue id @param validUntil th

Remove a specific breakpoint. Also remove all step attempts which are paused due to the breakpoint if request specified. If the number of paused step

Check if matched signal trigger indeed will cause a workflow execution. @param match matched signal trigger @return 1 if going to execute a workflow,

Try to unblock failed workflow instances for a given workflow id by set their status to FAILED_1. It does the batch update. If there is any update, it

Add one instance with its status into the pending buffer.

get STRING_MAP type (Java Map<String, String> type) param. @return concrete parameter object.

get SubworkflowArtifact type artifact. @return concrete artifact object.

Deactivate the workflow with a provided workflow id. @param workflowId workflow id @param caller caller info @return timeline info

Delete the flow after it is completed. Note that flow table cannot provide uniqueness guarantee due to this. A flow can be created and then completed

Convert a signal request to a signal instance (missing seq id). The sequence id will be set later.

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

Get callback for the step instance current runtime state.

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

get parameter evaluated result in string format.

Get step failure mode.

Get a batch of flows for a given flow group from the provided flow id cursor. @param group flow group to fill @param limit limit in one batch @param

Get iteration count from the running stats map. @param strict if true, count the total number of instances after the smallest running iterations,

This is not thread safe and can only be called by the flow actor itself.

Get workflow identity.

encode a long value into a hash key.

This method scans the previous foreach step overview and then find out the maximum iteration id launched previously. It also sets its own details by u

Inject runtime parameters based on the step definition data. @param workflowSummary workflow summary @param step step definition @return an immutable

Upsert output data object. @param outputData output data

Return true if the char sequence is null or empty.

Launch a kubernetes job. @param context Kubernetes step context. @return Kubernetes job result.

Load runtime parameters based on the step type and its subtype. @return a collection of runtime generated parameters to inject @param workflowSummary

Calculate next execution date after start date for a given time trigger. @param trigger time trigger object @param startDate start date @param unique

Push a time trigger execution message. @param execution time trigger execution message @param delaySecs delay in seconds

encode a long value into a range key with predefined constant length MAX_RANGE_KEY_LENGTH. We use variable length

Add a list of new workflow instance runs (i.e. run_id=1). The instance list has already been sized to fit into the batch size limit. It will skip inst

Create a concrete upstream initiator based on the given type.

Add fields to data.

overridden build method.

Build notebook parameters and return the full JSON string. @return The full JSON string

Accept the visitor.

Retry the un-owned message after the current ownership is timed out. It will put a lock in the queue_lock table to ensure that only one worker can deq

Return the group id for given workflow instance. It should be deterministically and evenly distributed. We don't include the run id in the groupingKey

Run the flow's final callback function.

Return nextPollingDelayInMillis value and reset its value.

Return default workflow params to be injected. @return default workflow params

get field from data by the field name.

fetch a batch of flows using flow dao. @param group flow group to load flows @param limit maximum number of flows to load @param idCursor flow id cur

assemble the inline workflow id prefix based on workflow internal id.

Get the next Token.

Get the latest step attempts of all the steps for a given workflow instance run (workflow id, instance id, run id). @param workflowId workflow id @pa

Return the step tag permit status code of a step instance. @param uuid step uuid @return status, -1 if not found, 7 is acquired, otherwise, still wai

start up.

Insert the flow into the flow table. It ensures the current flow group generation is correct so making sure the ownership is not expired. There is no

Convert a Map of raw objects to a Map of ParamDefinitions. @param dslParams the raw param map @return map of ParamDefinitions

Split a large list into a list of small batches with a size no greater than batch size.

Preprocess a step event by fetching the workflow instance from maestro-server.

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

Check if there is any iteration in a given status.

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

Convert param definition to parameter.

Unblock the failed workflow instances with a provided workflow id. <p>todo: this might not work well if there are millions of failed instances. If ne

Validate and parse a URL string to prevent SSRF attacks. @param url the URL string to validate and parse @return the parsed URI @throws MaestroValida

Add an event to the timeline if not identical to the latest event.

Annotates a {@link MaestroTracingContext}.

Get Kubernetes type artifact. @return concrete artifact object.

get STRING_MAP type (Java Map<String, String> type) paramDefinition. @return concrete parameter definition object.

Asserts the expression is refused with the given cause type and message substring. Evaluation runs on a worker thread, so a failure surfaces as Execut

Retreat.

build method with param type check.

Calculate earliest execution date for time triggers. @param timeTriggers an array of time triggers with watermark @return the earliest date

Static method to create an WorkflowInstanceUpdateJobEvent. @param oldStatus old status @param newStatus new status @return status pending change even

Create workflow run requests within subworkflow and foreach steps.

Get the current restart workflow id.

Get synced tag permits starting from the given cursor (exclusive) with the given limit. @param cursor the last tag from previous batch, pass empty st