newTaggedLogger returns a logger tagged with the Scheduler's attributes.

pollFromDeployment calls PollWorkflowTaskQueue to start deployment related workflows

preValidateActive track a task and return if validation should be done, if namespace is active

preValidatePassive track a task and return if validation should be done, if namespace is passive

propagateTimeSkippingToNextRun propagates both time skipping config and state to the next run in the chain (CaN, retry, cron). The config is deep-clon

removeNexusOperation removes a Nexus operation from the workflow.

rollbackTaskQueueToVersion simulates routing config lag by rolling back the task queue user data to an older version with revision number 0. This is u

routeSystemCallbackRequest routes a system callback request to the appropriate frontend client based on the callback token's namespace and active clus

runSentinelHandlerTestCase asserts that the given operation returns NotFound when invoked on a sentinel scheduler.

Update test utilities

tagsCacheKey builds a compact string key from a tag slice for use as a map lookup key.

Unloads the given task queue partition. If it has already been unloaded (i.e. it's not present in the loaded partitions map), then does nothing. parti

call with matcherData.lock held. w.matchResult must be nil (can't call wake twice). w must not be in queues anymore.

Sticky queue needs to be created in server before tasks can schedule in it. Call to this method create the sticky queue by polling it.

Admit returns true iff currentCluster appears in the task's replication config cluster list.

AllMatchingBehaviors returns all 8 combinations of matching behaviors for testing.

AssertNotFired asserts that the callback was not triggered.

AvailableMemberCount returns the number of hosts running this service that are accepting requests (not draining).

AwaitTruef is like [AwaitTrue] but includes a format string appended to the failure message.

BaseURL is the scheme and address of this HTTP client.

BuildCLIOptions builds the options for cli

ChasmSignalBacklinksEnabled returns true if CHASM-based signal requestID backlink tracking is enabled.

ChasmWorkflowComponentReadOnly gets the root workflow component from the CHASM tree. Returns both the workflow component and a read-only CHASM context

ClearActivityStartedState resets the per-attempt "started" fields on an ActivityInfo. Called when an activity leaves the started state (retry, pause,

CompareState compares two state objects. It should return 0 if the states are equal, a positive number if the first state is considered newer, a negat

Component retrieves a component from the tree rooted at node n using the provided component reference It also performs access rule, and task validatio

ControlQueueName returns the Nexus task queue name used to deliver control tasks to this worker.

Copy VersionHistories.