Retry operation on transient error.

extractAllTestRuns extracts all test runs (including successes) from parsed JUnit data Used for calculating failure rates

extractApplicationErrorOrInternal extract application error from update failure preserving error type and retriability. If the failure is no-nil but n

extractArtifactZip extracts zip file and returns paths to JUnit XML files

extractFailures extracts all test failures from parsed JUnit data Filters for: passed = false AND skipped = false (matching tringa SQL query)

extractMultiOperation extracts routing key from ExecuteMultiOperationRequest. The routing key is extracted from the first operation's StartWorkflow re

fabricateStartedEventIfMissing adds a NEXUS_OPERATION_STARTED history event and transitions the operation to NEXUS_OPERATION_STATE_STARTED if it has n

failCmd builds a FailWorkflowExecution command with a bare Failure{Message: msg}. Such a failure carries no specific FailureInfo, so retry.isRetryable

TODO (alex): replace this with t.s.failover()

Format the log.Logger tags and such into a useful message

fastForwardTaskIsLive returns false when the task should be dropped silently — either time skipping has been disabled since the task was emitted, or t

fetchCommitMeta fetches commit title, author, and changed file list for a single commit SHA. Uses: GET /repos/{owner}/{repo}/commits/{sha}

fetchCommitMetasParallel fetches commit metadata for a list of SHAs concurrently, bounded by maxConcurrency. Returns an immutable map of SHA → CommitM

fetchRunArtifacts retrieves all artifacts for a specific workflow run

fetchTasks collects getReplicationTasks request from shards and send out aggregated request to source frontend.

fetchWorkflowRuns retrieves all completed workflow runs within a date range. since is the oldest bound (inclusive); until is the newest bound (zero me

fieldPathToAccessor converts a dot-separated proto field path to a Go getter chain. E.g. "workflow_execution.workflow_id" → "r.GetWorkflowExecution().

nolint:revive // cognitive complexity 29 (> max enabled 25)