atproto_firehose subscriber: delay reconnecting on exception as well as disconnect

pull/1534/head
Ryan Barrett 2024-11-20 19:59:29 -08:00
rodzic ae4c758d44
commit 9e5d7fa3ac
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 6BE31FDF4776E9D4
1 zmienionych plików z 2 dodań i 2 usunięć

Wyświetl plik

@ -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():