diff --git a/pytr/dl.py b/pytr/dl.py index 28faca3..c51341d 100644 --- a/pytr/dl.py +++ b/pytr/dl.py @@ -71,7 +71,9 @@ async def dl_loop(self): try: _, subscription, response = await self.tr.recv() except TradeRepublicError as e: - self.log.fatal(str(e)) + self.log.error(f"Error response for subscription \"{e.subscription}\". Re-subscribing...") + await self.tr.subscribe(e.subscription) + continue if subscription.get("type", "") == "timelineTransactions": await self.tl.get_next_timeline_transactions(response)