-
Notifications
You must be signed in to change notification settings - Fork 6
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
Specs/grains observation #1573
Specs/grains observation #1573
Conversation
…atching up events for partitions after retrying or handling failed partitions
… so that it saves its grain state after it is changed
…tate and can handle events in a specified range instead of always all events
…ries starting the docker container up to 10 times. This is helpfull when running integration tests back to back
…ecs/grains-observation
…ecs/grains-observation
Follow up tasks from this is to go over the job system with specs and then move over to through integration testing |
Source/Kernel/Grains/Observation/Jobs/HandleEventsForPartition.cs
Outdated
Show resolved
Hide resolved
Co-authored-by: Einar Ingebrigtsen <[email protected]>
Co-authored-by: Einar Ingebrigtsen <[email protected]>
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.
Great work! Much needed refactorings!
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.
Approving the rest of the PR, as long as it builds with the proposed changes
c894173
to
214a772
Compare
Summary
In the process of adding specs to the Observation system many smaller issues were discovered and fixed. Along with general code cleanup and refactoring.
Added
Changed
Fixed
JobStep
did not save state when pausedRemoved
Handled
from ObserverState counting the number of handled events. This can be done differently in the future