filterParentTests removes top-level test names from grouped when subtests of that parent were observed in testRunCounts. A top-level failure whose sub

fireBackgroundTimer waits for the worker to register its periodic timer and then advances the fake clock past the timer's deadline.

fireTimers fires all timers that are ready.

generateReport builds a JUnit report for failures that the runner derives itself, such as timeouts and crashes. Failure.Type stores the canonical fail

generateTestReportTable creates a markdown table of test reports with rate column.

bucketFor hashes the namespace to select a bucket.

TODO: task type tag value should be generated from enums.TaskType, but this is a non-trivial change, we will need to 1. Standardize existing naming in

GetChasmTaskEventID is a dummy getter for CHASM tasks, as Components don't have events.

getDroppedTaskExpiryReason returns the drop reason for a task being dropped due to in-memory expiry or validation failure.

getExecutionLease returns shard context and mutable state for the chasm execution, with the lock held. An error is returned if the state transition sp

Helper methods getFirstWFTaskCompleteEventID finds the first event corresponding to workflow task completion. This can be used as a good reset point f

getInvalidTaskTag returns the tasks_expired stage tag for a task being dropped due to in-memory expiry or validation failure.

ack manager

getPhysicalQueuesForAdd returns two physical queues, first one for spooling the task, second one for sync-match spoolQueue will be nil iff the task is

Returns physicalTaskQueueManager for a task queue. If not already cached, and create is true, tries to get new range from DB and create one. This does

logInternalError emits a log statement for internalMsg, tagged with both internalErr and a reference-id. An opaque error containing the reference-id i

makeRunsForTest creates a slice of TestRun with the given total count and failure count. The first `failures` runs are marked as failed, the rest as p

maybeValidate checks if a task has expired / is valid if return false, then task is invalid and should be discarded if return true, then task is *mayb

newForwarder returns an instance of Forwarder object which can be used to forward api request calls from a task queue child partition to a task queue

persistence helper

newPartitionCache returns a new partitionCache. Start() must be called before using it.