add sleep
This commit is contained in:
parent
4c7cef570f
commit
6b5d71049e
@ -217,7 +217,6 @@ class ExternalMessageConsumer:
|
|||||||
) as e:
|
) as e:
|
||||||
logger.error(f"Connection Refused - {e} retrying in {self.sleep_time}s")
|
logger.error(f"Connection Refused - {e} retrying in {self.sleep_time}s")
|
||||||
await asyncio.sleep(self.sleep_time)
|
await asyncio.sleep(self.sleep_time)
|
||||||
|
|
||||||
continue
|
continue
|
||||||
|
|
||||||
except (
|
except (
|
||||||
@ -225,6 +224,7 @@ class ExternalMessageConsumer:
|
|||||||
websockets.exceptions.ConnectionClosedOK
|
websockets.exceptions.ConnectionClosedOK
|
||||||
):
|
):
|
||||||
# Just keep trying to connect again indefinitely
|
# Just keep trying to connect again indefinitely
|
||||||
|
await asyncio.sleep(self.sleep_time)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
Loading…
Reference in New Issue
Block a user