initializeWorkflowAssignedBuildId sets the wf assigned build ID after scheduling the first workflow task, based on the build ID returned by matching.

installEngineCapturingSpeculativeTimeout wires a mock engine onto the test shard whose NotifyNewTasks records each WorkflowTaskTimeoutTask it receives

TODO(bergundy): Merge this with the interceptRequest method in nexus_handler.go.

isAncestorOf returns true if n is a proper ancestor of descendant. It walks from descendant up through parent links to check if n is encountered.

nolint:revive // explicit cases in switch for documentation purposes

Returns true when the error is expected and should be retried. You're expected to return an error in this case, as that possible-rewritten-error is wh

isInAnyPath checks if the file is within any of the specified paths

same as Go's version

isNexus returns true if the underlying task is a nexus task

isNilPayload checks if the payload is equivalent to nil. There are four cases: - payload object is nil - payload's data is nil - payload's data is "nu

isPartiallyRampedAssignmentRuleTarget checks whether the given buildID is the target of a partially-ramped assignment rule (one with a ramp < 100). We

isRetryableTaskError reports whether a failed task's error permits a retry.

isStateDirty is used upon closing transaction to determine if application data has been updated, and mutable state should move to a new versioned tran

isStdinPiped reports whether stdin is connected to a pipe or file rather than a terminal.

isSystemWorker determines if a worker is a system worker. If a principal is available, it checks whether the principal identifies the Temporal server

isTaskQueueExpectedInNewVersion checks if a task queue is expected in the new version. A task queue is expected in the new version if: 1. It is not as

isTestFunc returns true for func TestXxx(t *testing.T).

isWorkflowStarted returns true if a workflow with the given ID has already been started (has a RunId set).

listAndFilterByName paginates over all endpoints returned by persistence layer to find the endpoint name indicated in the request. Returns that endpoi

List all queues

listTypes lists the User defined types in a Keyspace

loadAndValidateMutableState loads mutable state and validates it. Propagages errors returned from validate. Reloads mutable state and retries if valid

loadArgs loads the cancel arguments from the cancellation and its parent operation.

loadArgsForCancelation loads state from the operation state machine that's the parent of the cancelation machine the given reference is pointing to.

loadLegacy loads configuration data from a set of YAML files located in the config directory. Deprecated: This loader is maintained only for backward

loadSQLiteConfig loads the config for the sqlite persistence store. We use sqlite because it doesn't require any external dependencies, so it's easy t