Skip to content

Commit b86e41f

Browse files
Single-threaded subscription evaluation (#2682)
1 parent e727090 commit b86e41f

2 files changed

Lines changed: 237 additions & 327 deletions

File tree

crates/core/src/subscription/module_subscription_actor.rs

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

697697
match &event.status {
698698
EventStatus::Committed(_) => {
699-
update_metrics = subscriptions.eval_updates(&delta_read_tx, event.clone(), caller);
699+
update_metrics = subscriptions.eval_updates_sequential(&delta_read_tx, event.clone(), caller);
700700
}
701701
EventStatus::Failed(_) => {
702702
if let Some(client) = caller {

0 commit comments

Comments
 (0)