reapplyChildEvents reapplies all child events except EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED. This function is intended to pick up all the

reconcileMetadata merges the current metadata with the new metadata, modifying the new metadata in place.

recordCallOutcome records metrics and logs errors for the outcome of an outbound Nexus call.

recordChildWorkflowCompleted records the child completed event in the parent history if the parent is still running. It returns consts.ErrWorkflowComp

recordDuplicateExecuteDrops emits a metric + Debug log for CompletedStarts that were dropped because a concurrent ExecuteTask already recorded the Run

recordEvictionMetric sets the eviction metric based on current capacity state. Assumes EvictByCapacity has already been called.

recordFailure stores the first observed failure (first-failure-wins via CAS). Tags are copied so the recorded value is independent of the caller's sli

recordProcessBufferResult updates the Invoker's internal state based on result, as well as the LastProcessedTime watermark. Tasks to continue executio

recordScheduleToStartOrCloseTimeoutFailure records schedule-to-start or schedule-to-close timeouts. Such timeouts are not retried so we set the outcom

Checks if data in db has not been modified since we loaded/modified it.

gRPC utilities

releaseManagedState relinquishes a previously-applied managed scale target back to the dynamic-config baseline by zeroing Target and PrivateScalerStat

remove returns the next task from run queue if there are no active tasks in runq, a task from deferredQ is returned

removePollerFromHistory eagerly removes the worker from pollerHistory so DescribeTaskQueue doesn't show stale pollers after worker shutdown.

removeTest drops t from the active set and reports whether the set is now empty.

renderMarkdown renders a SlackMessage as markdown, treating each block's text as markdown.

replayWorkflowHistory replays a single workflow history file and validates it