-
Notifications
You must be signed in to change notification settings - Fork 182
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
refactor(torii): queries for them to not block #2391
Conversation
9988fdb
to
e1f12c7
Compare
commit-id:6c5aebce
e1f12c7
to
6cca479
Compare
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## spr/main/b4b488fe #2391 +/- ##
=====================================================
+ Coverage 68.28% 68.30% +0.02%
=====================================================
Files 357 357
Lines 47257 47310 +53
=====================================================
+ Hits 32270 32316 +46
- Misses 14987 14994 +7 ☔ View full report in Codecov by Sentry. |
|
||
update_entity.updated_model = Some(wrapped_ty); | ||
self.query_queue.push_publish(BrokerMessage::EntityUpdated(update_entity)); | ||
self.query_queue.push_publish_query( |
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 should ensure that set_model_member also works when parallelized
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.
any reason it wouldn't work?
@@ -291,6 +292,7 @@ impl<P: Provider + Sync> Relay<P> { | |||
peer_id = %peer_id, | |||
"Message set." | |||
); | |||
self.db.execute().await.unwrap(); |
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 should also execute the queries for the set_entity that is further down. Can we refactor the logic here to reuse the same self.db.execute() everywhere? We can add a function that sets the entity and directrly executes the db queries
closing in favour of #2397 |
Stack: