spawnBlockedRequests sends a bunch of requests to the interceptor which will block until signaled.

specialCaseAPIIsPolling checks if an API is a long-polling API and should be excluded from health signals. Note that this interceptor may run in multi

splitStatsByPriorityByRampPercentage splits each priority bucket independently by ramp percentage. This is required so that TaskQueueStatsByPriorityKe

splitTaskQueueStatsByRampPercentage splits a task queue stats record into "current" and "ramping" shares. This split is applied independently per prio

Run an update in cluster1 to Accepted state, failover to cluster0, and confirm that it can be completed in cluster0.

startAndUpdateNew creates a new execution, applies startFn and updateFn in the same transaction, and registers it as the current run for the business

startNewForClosedExecution handles starting a new execution when we already hold a lease on a closed execution. It creates the new execution first, th

startVersionedPollerAndValidate starts a versioned poller for the given task queue and validates that the version is present in the task queue via mat

startWatch attempts to establish a namespace watch with retries. Returns the watch channel and context on success.

startWorkflowDeadline returns the latest time at which a buffered workflow should be started, instead of dropped. The deadline puts an upper bound on

startWorkflowSearchAttributes returns the search attributes to be applied to workflows kicked off. Includes custom search attributes and Temporal-mana

startWorkflows executes the provided list of starts, returning a result with their outcomes.

structuredRef returns a ComponentRef for the node.

subscribe returns a channel that will be closed on the next notify call for key, and an unsubscribe function that must be called when the caller is do

sweepIdleQueues removes queues that have been idle for longer than QueueTTL. Returns true if no queues remain (sweeper should exit).

syncRegisteredTaskQueueAsync syncs the routing config and version data to the new task queue. This method does not increment version data revision num

syncVersionStatusAfterDrainageStatusChange syncs the current version status to all task queues. This function acquires the workflow lock the same way

syncVersionSummary ensures the version summary in the deployment workflow stays consistent with the version workflow. This helps prevent discrepancies