-
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
Combine events #224
Combine events #224
Conversation
Codecov Report
@@ Coverage Diff @@
## main #224 +/- ##
==========================================
+ Coverage 90.37% 90.80% +0.42%
==========================================
Files 40 40
Lines 1174 1174
==========================================
+ Hits 1061 1066 +5
+ Misses 113 108 -5
... and 2 files with indirect coverage changes 📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
src/blueapi/cli/amq.py
Outdated
@@ -51,12 +51,13 @@ def on_progress_event_wrapper( | |||
on_progress_event(event) | |||
|
|||
self.app.subscribe( | |||
self.app.destinations.topic("public.worker.event"), on_event_wrapper | |||
self.app.destinations.topic("public.worker.events"), on_event_wrapper |
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.
We say: How come it's changed to events from event - the convention for topics/queues is singular (we believe)
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 wasn't aware of the convention, I'll change it back no problem
Provides a test to ensure data and worker events from seperate dedicated streams are published to the same topic in correct sequential order.
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.
@abbiemery are you happy with the changes Peter made, and for this to be merged now?
Fixes #176
I would really appreciate someone looking over the test in
test_reworker
for the ordering ofWorkerEvents
andDataEvents
and the ordering of the types ofDataEvents
. I got quite caught up in the type system here. It appears to be beyond the reach of pythons typing to accurately type this, as backed up by @WareJosephB , however I could be wrong. I tried to explain the issue in a docstring of the offending function but again, could easily have tripped up my explanation here.