Skip to content

Commit 57fa1dd

Browse files
Single-threaded subscription evaluation
1 parent c30cdea commit 57fa1dd

File tree

2 files changed

+245
-282
lines changed

2 files changed

+245
-282
lines changed

crates/core/src/subscription/module_subscription_actor.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -685,7 +685,7 @@ impl ModuleSubscriptions {
685685

686686
match &event.status {
687687
EventStatus::Committed(_) => {
688-
metrics.merge(subscriptions.eval_updates(&read_tx, event.clone(), caller));
688+
metrics.merge(subscriptions.eval_updates_sequential(&read_tx, event.clone(), caller));
689689
}
690690
EventStatus::Failed(_) => {
691691
if let Some(client) = caller {

0 commit comments

Comments
 (0)