validateBuildIdRedirectInfo validates build ID for the task being dispatched and returned the redirect counter that should be used in the task started

validateClusterNotInUseByNamespaces returns an error if any active multi-cluster namespace still references clusterName in its replication cluster lis

validatePartitionCounts checks whether a partition should accept an RPC based on the current scale info. It returns nil if the RPC should be accepted,

validatePartitionScaleDrift checks whether a partition should accept an RPC based on the client's idea of partition counts. It returns nil if the RPC

validatePinnedVersionExistsInTaskQueue validates that the version, to be pinned, exists in the task queue. TODO (future improvement): This can be furt

validateRetentionDuration ensures that retention duration can't be set below a sane minimum.

validateSchedulePayloadSize validates the blob size of the schedule's memo and action input. This runs for both CHASM and V1 paths.

Validates inner start workflow request. Note that this can mutate search attributes if present.

validateWorkflowState validate workflow state

validateWorkflowStatus validate workflow status

verifyOwnership checks if the shard should be owned by this host's shard controller. If membership lists another host as the owner, it returns a Shard

verifyReusePolicy checks if a given workflow was started with REJECT_DUPLICATE

call with matcherData.lock held

waitUntilWorkflowReplicated waits until the workflow with the given ID has been replicated to the standby cluster. It does this by waiting for the rep

workflowKeyFromTask extracts namespace ID, workflow ID, and run ID from the replication task. It first tries RawTaskInfo, then falls back to task-type

This is a helper function to make it easier to change the DLQWriteRequest format in the future.

AbortAccepted aborts all accepted Updates in the Registry.

AckLevel returns tag for ack level

ActivitySize returns a tag for a standalone activity size

AddCompletionCallbacks creates completion callbacks using the CHASM implementation. maxCallbacksPerWorkflow is the configured maximum number of callba

AddExitVertex adds the terminate history event vertex

AddFirstWorkflowTaskScheduled adds the first workflow task scheduled event unless it should be delayed as indicated by the startEvent's FirstWorkflowT

AddIncomingSignalEvent adds an entry for the signal requestID -> eventID mapping to track all signals that have been received by the workflow. Note th

AddInitialEntryVertex adds the initial history event vertices Generator will only start from one of the entry vertex

AddUpdateCompletionCallbacks creates completion callbacks using the CHASM implementation. maxCallbacksPerWorkflow is the configured maximum number of