scheduleTask schedules a GeneratorTask at the given time.

schedulesInNamespace returns an iterator over the business IDs of every schedule matching query in the given namespace (scoped to the Scheduler archet

This is only exposed for testing!

setNullableFields sets fields that are nullable in API requests.

TODO (Shivam): We may have to wait for the propagation status to show completed if we are using async workflows here.

setupTestInfra creates the common test infrastructure for scheduler tests.

Shardupdate returns tag for Shardupdate

shouldIncludeTransientOrSpeculativeTasks determines if transient/speculative events should be included. This function is called only when on the last

signalIfFatal calls UnloadFromPartitionManager of the physicalTaskQueueManager if and only if the supplied error represents a fatal condition, e.g. th

signalIfFatal calls UnloadFromPartitionManager of the physicalTaskQueueManager if and only if the supplied error represents a fatal condition, e.g. th

signalPartitionScaler sends a signal to the partition scaler that a new task has arrived (directly from history, not forwarded).

signalWithStartWorkflow invokes the SignalWithStart handler using the System Nexus Endpoint, and NOT the typical frontend API directly. This is a newe

sizeOfChasmNodeMap is a special case since the persistence interface separates a node's metadata and data fields.

splitHostPortTyped expands upon net.SplitHostPort by providing type parsing.

startAndCompleteWorkflow starts a workflow and immediately completes it by responding to its first workflow task. Returns the run ID of the completed

startNew creates a new execution and registers it as the current run for the business ID.

startTargetWorkflow starts a generic workflow.

takeNextAction increments the context's actionTaken counter, returning true if the action should be executed, and false if the task should instead yie

testPinnedCaNUseRampingVersionOnCaN tests that a Pinned workflow can ContinueAsNew to the ramping version using CONTINUE_AS_NEW_VERSIONING_BEHAVIOR_US

Verifies that a retry run starts on the same version the first run executed on, even if the task-queue partition's user data is rolled back to an olde

Simple tokenizer by spaces. It's a temporary solution as it doesn't cover tokenizer used by PostgreSQL or SQLite.

tryEvictUntilEnoughSpaceWithSkipEntry try to evict entries until there is enough space for the new entry without evicting the existing entry. the exis

tryReschedule attempts to reschedule the activity for retry. Returns true if rescheduled, false if retry is not possible.

unset stops the timer.

updateConflictToken bumps the Scheduler's conflict token. This has a side effect of invalidating the local cache. Use whenever applying a mutation tha

UpdatePerKeySimpleRateLimit updates the per-key rate limit for the simpleRateLimit implementation UpdateTaskQueueConfig api is the single source for t