logging i broker base.

ssi-dk · Dec 15, 2024 · b9d2ce4 · b9d2ce4
1 parent 80acc0d
commit b9d2ce4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/bifrost/bifrost_queue_broker/brokers/request/request_broker.py b/bifrost/bifrost_queue_broker/brokers/request/request_broker.py
@@ -52,6 +52,11 @@ def run(self):
 
             except StopIteration:
                 time.sleep(1)
+                if not cursor.alive:
+                    log.error(f"{self.broker_name} stop iterations was thrown and curser is not alive.")
+                    cursor = self.col.find(
+                        self.listener_match, cursor_type=CursorType.TAILABLE_AWAIT
+                    )
             else:
                 pass