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
Flush buffer event when failing workflow task #4010
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.
Can we add a test for this?
// Flush buffer event before failing the workflow | ||
ms.FlushBufferedEvents() | ||
|
||
attributes := &commandpb.FailWorkflowExecutionCommandAttributes{ | ||
Failure: wtFailedCause.workflowFailure, | ||
} |
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.
i believe there is a util which flush & fail the workflow, can we plz use that util?
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.
There is a util to fail workflow task and flush. This one is to flush before fail the whole workflow.
* Flush buffer event when failing workflow task
* Flush buffer event when failing workflow task
* Flush buffer event when failing workflow task
What changed?
Flush buffer event when failing workflow task
Why?
When workflow task failed due to payload/search attribute size too large, it should flush buffer events before fail the workflow.
How did you test it?
Potential risks
Is hotfix candidate?