Skip to content

Commit

Permalink
fix: commit message
Browse files Browse the repository at this point in the history
  • Loading branch information
skpdelegate committed Dec 15, 2024
1 parent b9d2ce4 commit 32e5d63
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ 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.")
log.error(f"{self.broker_name} stop iterations was thrown and curser is not alive, recreate it.")
cursor = self.col.find(
self.listener_match, cursor_type=CursorType.TAILABLE_AWAIT
)
Expand Down

0 comments on commit 32e5d63

Please sign in to comment.