UpdateTaskQueueUserData updates the user data for a set of task queues in one namespace. The request takes the _current_ known version along with the

ValidateConflictResolveWorkflowModeState validate workflow conflict resolve mode & workflow state

Wait blocks waiting for all goroutines spawned via `Go` on this `Group` instance to complete. If `Go` has not been called then this function returns i

Deprecated: this option is no longer required and will be removed once all callers have been updated.

WithT directs all worker and client logs to the test logger. If this option is specified, then server will automatically be stopped when the test com

WorkerDeploymentVersionS returns the internal server api WorkerDeploymentVersion (different from the public api WorkerDeploymentVersion).

Add a reset point for current task completion if needed. Returns true if the reset point was added or false if there was no need or no ability to add.

andAllChildren returns a sequence of all nodes in the tree starting from n, including n itself. The sequence is depth-first, pre-order traversal.

applyFastForward (re)computes the FastForwardInfo using the new TimeSkippingConfig (TSC) and propagated time-skippingstates. This method should be cal

attachLinks records the given links on the activity keyed by requestID. Duplicates within the same batch are skipped. If the requestID has already bee

checkReportedProblemsSearchAttribute is a helper function to verify reported problems search attributes

return reset points minus a few fields that are hard to check for equality

commitBuildID sends a CommitBuildId request for the given build ID It checks the response and returns the conflict token.

completeWorkflowCmd returns a CompleteWorkflowExecution command.

persistence helper

TODO: Remove this once older stats tests are refactored to use the createDeploymentOptions function.

extractMetadataFromTrailer reads context metadata from gRPC response trailers. It first checks for the proto-encoded "contextmetadata-bin" key, which

File I/O util

getDrainBacklogMgr returns the draining backlog manager, or nil if none.

getUpstreamBuildIds returns a list of build ids that point to the given buildId in the graph of redirect rules. It considers all rules in the input li

hasVisibilityField returns true if the given component type has a Field[*Visibility]. This is used at registration time to validate that archetypes us

isInVersionSets returns true if the given build ID is in any of the listed version sets

isSchedulerErrorLegacyRoutable returns true if the error from the CHASM scheduler indicates that the request should be routed to the legacy (V1) sched

logSumExpNormalize converts log-weights to probabilities using the log-sum-exp trick to avoid numerical underflow. Returns a slice of probabilities su

Returns the max of a and b.