-
Notifications
You must be signed in to change notification settings - Fork 877
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
Fix DeleteWorkflowExecution API when delete non current execution #2484
Fix DeleteWorkflowExecution API when delete non current execution #2484
Conversation
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.
The proto change is not related to this pr?
@@ -54,7 +53,7 @@ type ( | |||
) error | |||
GenerateDeleteExecutionTask( | |||
now time.Time, | |||
) error | |||
) (*tasks.DeleteExecutionTask, error) |
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.
return tasks.Task
or []tasks.Task
please.
Once queue refactor change is done, I am going to update all the generator methods to return the generated task, instead of adding it to ms directly.
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.
"Depend on interface, return concrete type", right? Unless there is a good reason for exception.
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.
Since we control the caller code and we can prevent them from being closely coupled, I don't really have a strong opinion here.
I was sure I merged this PR already. |
a73eeeb
to
0efa1eb
Compare
What changed?
Fix
DeleteWorkflowExecution
API when delete non current execution. Instead of calling internalupdateWorkflow
funcion, adding transfer task using newDeleteManager.AddDeleteWorkflowExecutionTask
function which essentially just callsshard.AddTask
.Why?
Previous implementation worked only for current workflows.
How did you test it?
Integration test in another PR.
Potential risks
No risks.
Is hotfix candidate?
No.