rpc bugfix

catenae · Sep 23, 2021 · 1cafc28 · 1cafc28
1 parent 39c4275
commit 1cafc28
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/catenae/catenae.py b/src/catenae/catenae.py
@@ -445,7 +445,12 @@ def _transform(self):
     def _rpc_notify_handler(self):
         no_messages = True
         for input_stream in self.config['rpc_topics']:
-            message = self.stopover.get(input_stream, self.uid)
+            message = None
+            try:
+                message = self.stopover.get(input_stream, self.uid)
+            except Exception:
+                pass
+
             if not message:
                 continue