-
Notifications
You must be signed in to change notification settings - Fork 266
Stop sending deployment info for session per-worker task queue #2088
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Conversation
| params.TaskQueue = sessionEnvironment.GetResourceSpecificTaskqueue() | ||
| // For the resource specific task queue, we don't need to include deployment options | ||
| // Save them to restore later | ||
| deployments := params.DeploymentOptions |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Only disable versioning instead of removing the whole thing? better to keep the deployment name and build id if user has given it (to keep in the events).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Does it make any difference for an activity only task queue? I don't see any difference in the history.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we might add the deployment options in activity events later
eddebc9 to
5fc9d01
Compare
| } | ||
|
|
||
| func (ts *WorkerDeploymentTestSuite) TestBuildIDWithSession() { | ||
|
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we want to gate this? All other tests here have this req
if os.Getenv("DISABLE_SERVER_1_27_TESTS") != "" {
ts.T().Skip("temporal server 1.27+ required")
}
| wfHandle, err := ts.client.ExecuteWorkflow(ctx, ts.startWorkflowOptions("evolving-wf-1"), "SessionBuildIDWorkflow") | ||
| ts.NoError(err) | ||
|
|
||
| ts.NoError(wfHandle.Get(ctx, nil)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What is this actually verifying? This seems to pass on master without your fix
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we be asserting that buildId and versioning settings for the session activity worker is properly set?
Stop sending deployment info for session per-worker task queue
Note
Temporarily disable deployment versioning on the session’s resource-specific activity worker and restore it for the creation worker; add a test validating Build ID behavior with sessions.
params.DeploymentOptions.UseVersioningandparams.UseBuildIDForVersioningwhen creating the session activity worker.TestBuildIDWithSessionverifying workflow execution under session with deployment versioning, plus relatedactivityimport.Written by Cursor Bugbot for commit 5fc9d01. This will update automatically on new commits. Configure here.