overrideDynamicConfigForTest overrides a dynamic config value for the duration of the test.

pickClientForWrite mutates the given proto. Callers should copy the proto before if necessary.

pretty-print the public state of the proto.Message. we don't use prettyPrint the way testify does as the private state isn't worth comparing; it's all

primaryTestName returns a single representative test name for an alert. Preference order: 1) Fully-qualified test name containing ".Test" 2) First det

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

TODO(pri): old matcher cleanup: move here func rangeIDToTaskIDBlock(rangeID int64, rangeSize int64) taskIDBlock { return taskIDBlock{ start: (range

readAndReplaceBody reads the response body in its entirety and closes it, and then replaces the original response body with an in-memory buffer. The b

recentActions returns started/completed actions as ScheduleActionResults. This includes both running workflows (with status RUNNING) and completed wor

Close and reopen the underlying database connection

recordCompletedPages records stats for each page that is now fully done and advances the heartbeat resume point to the oldest page that is not yet don

recordFailedAttempt records any failures resulting from a tried attempt, including worker application failures and start-to-close timeouts. Since the

remover is called when an Update gets into a terminal state (completed or rejected).

replaceInFile replaces text in a file using sed-like patterns

The scheduler task-lifecycle counters are emitted on two paths: "fired" (Validate=true, the task executed) and "invalidated" (Validate=false, with a R

requireNexusOperationError asserts that err is a WorkflowExecutionError with an inner NexusOperationError, and returns the inner NexusOperationError.

resetExcludedAPIs resets the package-level sync.Once and map so each test starts fresh.

resetMatcherState must be called before adding or re-adding a backlog task to priMatcher.

resolveUnsuccessfully finalizes the operation. When fromAttempt is true, the failure is recorded as LastAttemptFailure. Otherwise the failure is recor

runOverdueScan lists individual matching schedules per namespace, calls DescribeSchedule on each, and filters out schedules that are paused or expecte

scheduleActivityCmd returns a ScheduleActivityTask command that uses tv for all names / queue / timeout values.

setState updates the current scale state and syncs it to ephemeral data. This should only be called _after_ the state is persisted to the db. Called f

startSkippingWorkflow starts a workflow on the active cluster (cluster[0]) with the given TimeSkippingConfig and optional WorkflowStartDelay. Returns

startTargetWorkflowWithWorkflowID starts a workflow using the supplied Workflow ID.

startWorkflowWithTimeSkipping starts a workflow with time-skipping enabled and a caller-specified run timeout. Used by tests that need the run timeout

syncTaskQueuesAsync must be called within the lock. It first increments the version revision number and then starts async propagation of version data

syncUnversionedRamp should not be called in async mode

taskTimeoutContext derives a context bounded by defaultTaskTimeout for processing a single task. If the parent context already has a deadline that is

telemetryOverrideOperationTag is used to override scope used for reporting a metric. Ideally this method should never be used.

testSkipExpiredTasks verifies that the task reader correctly skips over expired tasks in the DB and advances the ack level past them.