Skip to content

Commit

Permalink
atproto_firehose subscriber: delay reconnecting on exception as well …
Browse files Browse the repository at this point in the history
…as disconnect
  • Loading branch information
snarfed committed Nov 21, 2024
1 parent ae4c758 commit 9e5d7fa
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions atproto_firehose.py
Original file line number Diff line number Diff line change
Expand Up @@ -122,10 +122,10 @@ def subscriber():
while True:
try:
subscribe()
logger.info(f'disconnected! waiting {RECONNECT_DELAY} and then reconnecting')
time.sleep(RECONNECT_DELAY.total_seconds())
except BaseException:
report_exception()
logger.info(f'disconnected! waiting {RECONNECT_DELAY} and then reconnecting')
time.sleep(RECONNECT_DELAY.total_seconds())


def subscribe():
Expand Down

0 comments on commit 9e5d7fa

Please sign in to comment.