-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Retry attempts to delete open workflow executions #3411
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
Retry attempts to delete open workflow executions #3411
Conversation
deab139
to
35fb1ce
Compare
a37cdc0
to
636101b
Compare
dcc261f
to
9753ac0
Compare
@@ -273,6 +280,12 @@ func (t *transferQueueTaskExecutorBase) deleteExecution( | |||
} | |||
} | |||
|
|||
if checkForPendingCloseExecutionTask { |
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.
IMO, it is cleaner to move this logic into processDeleteExecutionTask and keep deleteExecution() as it is.
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.
Definitely, but I wanted it to be there so that I don't have to load mutable state twice.
9753ac0
to
3a33c90
Compare
…ask before deleting an execution
3a33c90
to
aa528dc
Compare
This is for #3368. It adds a check to our transfer task processor which ensures that tasks are closed before deleting them.