diff --git a/server/reflector/processors/base.py b/server/reflector/processors/base.py
index a518c4e6..9ba971be 100644
--- a/server/reflector/processors/base.py
+++ b/server/reflector/processors/base.py
@@ -173,6 +173,7 @@ class Processor(Emitter):
         except Exception:
             self.m_processor_failure.inc()
             self.logger.exception("Error in push")
+            raise
 
     async def flush(self):
         """