From 9e5d7fa3ac32fba730c815c7a8e5ff555550985d Mon Sep 17 00:00:00 2001 From: Ryan Barrett Date: Wed, 20 Nov 2024 19:59:29 -0800 Subject: [PATCH] atproto_firehose subscriber: delay reconnecting on exception as well as disconnect --- atproto_firehose.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/atproto_firehose.py b/atproto_firehose.py index c8ee21cb..d9c7bf38 100644 --- a/atproto_firehose.py +++ b/atproto_firehose.py @@ -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():