Repository navigation
Conversation
THardy98
force-pushed
the
dev/sticky-activities
branch
2 times, most recently
from
October 21, 2026 12:01
34e6bb6 to
919da29
Compare
THardy98
force-pushed
the
dev/sticky-activities
branch
from
October 21, 2026 14:02
919da29 to
3f4b21b
Compare
THardy98
force-pushed
the
dev/sticky-activities
branch
3 times, most recently
from
October 21, 2026 23:41
8f28f3b to
07fd242
Compare
THardy98
force-pushed
the
dev/sticky-activities
branch
2 times, most recently
from
October 22, 2026 01:38
07fd242 to
5b870cc
Compare
This branch has not been deployed
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Add experimental workflow-session activities and worker session configuration, pinned to Core
0de941f3(temporalio/sdk-rust#1687, stacked on #1691 and extraction #1686).workflow.ActivitySessionOptions.workflow_session(); omitted options retain ordinary routing. The factory returns an immutable variant rather than exposing an empty/false options state.worker.WorkerSessionOptions()enables sticky activity polling. Optionalworker.SingleSessionOptions(stable_identity=...)selects lifetime dedication to a stable destination; the Python API and bridge reflect the session proto model.Focused tests
test_worker.py. The standalone affinity-forwarding test file is removed.new_worker, the default sandboxed runner, and real worker identities. They cover queued activity/retry colocation, ordinary routing to a separate queue, workflow resumption, persisted membership, offline replay, and backlog draining under activity-capacity pressure.Server integration scope
Target temporalio/temporal#12630 with
system.enableStickyActivityExecutionenabled for the test namespace. Seetests/worker/STICKY_ACTIVITY_INTEGRATION.mdfor the command and limitations.These integration tests disable eager execution and do not configure single-session isolation: the current server PR rejects that policy. They establish observed colocation, not direct observation of every physical queue delivery. Worker-loss recovery, relocation, timeout fallback, lifetime isolation, and AgentCore/WCI lifecycle remain outside this validation.
Validation
poe lint: passed, including all three type checkers.SQL logic error: no such table: namespaces; the existing ordinary resource-tuner control also timed out against that server. No server data/configuration was changed to work around it.git diff --check: passed.Open in Delta