processArchiveExecutionTask processes a tasks.ArchiveExecutionTask First, we load the mutable state to populate an archival.Request. Second, we unlock

processArtifactJob downloads and processes a single artifact

processArtifactsParallel downloads and processes artifacts in parallel with a worker pool Returns: all failures, all test runs, and count of successfu

processBackfill processes a Backfiller's BackfillRequest.

ProcessBuffer should return true if there might be more work to do right now. nolint:revive

processBuffer resolves the Invoker's buffered starts that haven't yet begun execution. This is where the decision is made to drive execution to comple

processBuildIdRedirectInfo validated possible build ID redirect based on the versioningStamp and redirectInfo. If a valid redirect is being applied to

processCloseCallbacksChasm triggers "WorkflowClosed" callbacks using the CHASM implementation.

processCloseCallbacksHsm triggers "WorkflowClosed" callbacks using the HSM implementation.

nolint:revive // cognitive complexity

processSingleTask processes a single batch task, bounding its execution with a per-task timeout so that one hung operation cannot block the task proce

TODO(pri): old matcher cleanup

processTaskWithRetries runs the task's operation, retrying retryable failures in place on this goroutine, and sends exactly one response on respCh per

processTrigger processes a Backfiller's TriggerImmediatelyRequest.

processWatchEvent handles a single namespace watch event by updating the cache and invoking state change callbacks.

protoFieldToGoName converts a snake_case proto field name to PascalCase Go name.

publishShardCountUpdate publishes the current number of shards that this controller owns to all shard count subscribers in a non-blocking manner.

queryAll returns all workflow executions in the archive.

queryVersionState queries the version workflow for its current state.

rateLimitState returns the whole-queue ready time and whether a per-key limit is in effect.

readExpectedCounts reads expected workflow counts from the expected_counts.txt file

initiated by the owning shard