We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6d2c12f commit d9d017aCopy full SHA for d9d017a
src/execution/live_updater.rs
@@ -210,7 +210,7 @@ impl SourceUpdateTask {
210
interval.tick().await;
211
let curr_change_stream_stats = change_stream_stats.as_ref().clone();
212
let delta = curr_change_stream_stats.delta(&last_change_stream_stats);
213
- if !delta.has_any_change() {
+ if delta.has_any_change() {
214
report_stats(&delta, "change stream");
215
last_change_stream_stats = curr_change_stream_stats;
216
}
0 commit comments