Bypass filters for empty events
@@ -73,6 +73,9 @@ pub async fn worker(
Ok(Some(event)) => {
trace!(?event, "got event");
+ if event.is_empty() {
+ trace!("empty event, by-passing filters");
+ } else {
let filtered = working.borrow().filterer.check_event(&event);
match filtered {
Err(err) => {
@@ -88,6 +91,7 @@ pub async fn worker(
trace!("filter passed event");
}
}
+ }
if set.is_empty() {
trace!("event is the first, resetting throttle window");
