-
Notifications
You must be signed in to change notification settings - Fork 525
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
[Processor] Add a control message to inform the processor that draining is done #3153
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.
Nice work, added some comments below.
It would be nice to see how does it improve the drain flow.
Also, a test verified that it was called could also be good - perhaps by checking function logs?
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.
Nicely done 👌
only one minor comment
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.
Good job 👍
only a minor comment change but approved
At present, we lack a signaling mechanism to notify the processor when draining is complete. Currently, the processor relies on a timeout, which is not the most efficient approach. Even if draining takes less than a second, we still wait for around 10 seconds.
To address this issue, we are introducing a new control message -
DrainDoneMessageKind
. This message allows the wrapper to inform the processor when draining is done.Jira - https://jira.iguazeng.com/browse/NUC-124