assertPausedWorkflowTimesOut starts env.workflowFn (which blocks on its activity), pauses it, and asserts that the configured wall-clock timeout still

assertReappliedUpdateInNewRun verifies that updateID appears as an UpdateAdmitted event in runID's history with completion callbacks preserved.

buildCallbackInfoFromChasm converts a single CHASM callback to API format.

buildFtsSelectStmt builds the following statement for querying FTS: SELECT rowid FROM tableName WHERE tableName = '%s'

buildFtsSelectStmt builds the following statement for querying FTS: SELECT rowid FROM tableName WHERE tableName = '%s'

buildObservations groups TestRun records for a single (normalized) test name by commit SHA and returns them sorted chronologically using the commit or

buildPaginationQuery builds the Elasticsearch conditions for the next page based on searchAfter. For example, if sorterFields = [A, B, C] and searchA

buildRunTeardownCluster creates a dedicated cluster, runs a trivial workflow on it to exercise the full server path, then tears it down.

bulkBeforeAction is triggered before bulk processor commit

callScaler runs the scaler on the accumulated batch and persists the resulting state if it changed. Called from backgroundWork only.

capTombstoneCount limits the total number of tombstones stored in the mutable state. This method should be called whenever tombstone batch list is upd

Panic handler and metrics recording function. Used as a deferred statement in Nexus handler methods.

captureStack returns a formatted stack trace, skipping the first `skip` frames (including the captureStack frame itself).

chasmSchedulerCreationEnabled returns true when CreateSchedule should create on the CHASM scheduler. The binary EnableCHASMSchedulerCreation flag is g

checkRedirectConditions checks for validity conditions that must be assessed by looking at the entire set of rules. It returns an error if the new set

checkTestShard supports test sharding based on environment variables. This distributes tests across multiple CI shards for parallel execution.

checkVersionMembershipAndReactivationEligibility calls matching to check if a task queue belongs to a version and whether the version is currently act

checkWorkflowCallbackLimit returns an error if adding newCount callbacks would exceed the per-workflow maximum.

classifyFailures separates failures into categories. Classifies using the raw failure name (not the normalized key) since normalizeTestName strips suf

clearVersionFromRoutingConfig clears current/ramping fields in new-format routing config when an old-format DeploymentVersionData's roles change.

clone db.subqueues so we can return it outside our lock

Visibility tasks are collapsed into a single one: START < UPSERT < CLOSE < DELETE Their enum values are already in order, so using them to make the co