parseSQLVal handles values for specific search attributes. Returns a string, an int64 or a float64 if there are no errors. For datetime, converts to U

parseTestTimeouts parses the stdout of a test run and returns the stacktrace and names of tests that timed out.

parseTripleDashTestName parses Go test failure lines and returns the test name if present.

pct returns percentage of num/denom, returning 0 if denom is 0.

persistCallback writes a single WorkflowExecutionOptionsUpdatedEvent to attach the given requestID and completion callbacks, and deduplicate on reques

revive:disable-next-line:cognitive-complexity

pollWorkflowTasks polls tasks sequentially

predicatesEqual assumes there's no duplication in the given slices of predicates

prefixScheduleIDSQLValues returns a copy of the SQL value expression with the V1 schedule WorkflowId prefix prepended to each string literal. Handles

prepareSchedulerQuery validates a scheduler RPC's query argument, and wraps it in the appropriate base query.

Validates the request and sets default values where they are missing.

printTask writes a single task's dispatch info to the writer.

processConfigFile processes a config file, rendering it as a template if enabled

processInputPartition returns a partition in certain cases that load balancer involvement is not necessary, otherwise, returns a task queue to pass do

processServiceFile enumerates all methods in a service file and adds excluded categories to excludedAPIs.

processTask records stats for a dispatched task and returns the latency.

processUpdateCallbacks triggers "UpdateFinished" callbacks using the CHASM implementation.

processWorkflowsWithProactiveFetching handles the core logic for both batch activity functions nolint:revive,cognitive-complexity

TODO: Remove this implementation once transition history is fully implemented.

Publishes versioned and unversioned entities; with one entity per priority (plus default priority). Multiplied by `sets`.

purgeMessages from the DLQ up to and including the specified message ID, blocking until the purge workflow completes.

Put puts a new value associated with a given key, returning the existing value (if present) allowUpdate flag is used to control overwrite behavior if

queryPrefix returns all workflow executions in the archive that match the given prefix. The keyFilter function is an optional filter that can be used

readManifest reads the json manifest at dirPath into a manifest struct.

rebuild rebuilds a workflow, in case of any kind of corruption

rebuildableCheck checks if the mutable state is rebuildable error: - serviceerror.NewInvalidArgument: if the mutable state is not rebuildable - other

record sends a logRecord to the logs channel. If there is no active receiver, the logRecord will be dropped.

recordPayloadMetrics should be called after the customer's action is updated (or when the schedule is created) to record the size of their payloads.

recordActionResult updates the Scheduler's customer-facing metrics. RunningWorkflows and RecentActions are computed from BufferedStarts.

recordArchiveTargetResult takes an error pointer as an argument so that it isn't passed-by-value when used in a defer statement (this would make the e

recordCompletedAction updates Invoker metadata and kicks off tasks after an action completes. It marks the BufferedStart as completed by setting the C

recordExecuteResult updates the Invoker's internal state with the results of a completed InvokerExecuteTask. It returns the number of *new* actions re

To add tasks to the matcher: call recordNewTasksLocked with tr.lock held, then release the lock and call addNewTasks. We call addTaskToMatcher outside

recordOperationTimeout records the NEXUS_OPERATION_TIMED_OUT history event and transitions the operation to timed-out. It does NOT emit metrics; the c