-
Notifications
You must be signed in to change notification settings - Fork 36
(fix): refactor batch_event_processor to reset deadline after it passes. #227
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
Conversation
…o, hang on queue with timeout at flush interval
1 similar comment
Fix looks fine to me. Do we need additional unit tests for this 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.
Lgtm
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.
Synced with Tom and Mike on this. Changes make sense.
LGTM
@@ -159,9 +159,9 @@ def _get_time(self, _time=None): | |||
Integer time in seconds. | |||
""" | |||
if _time is None: | |||
return int(round(time.time())) | |||
return time.time() |
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.
Please change the description of the method.
Also Returns, valid time, can be float and integer. Need to revise documentation.
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.
lgtm
Also, hang on queue with timeout at flush interval
Summary
Test plan
Current tests should pass
Issues