fix: unused params

This commit is contained in:
Vlad Stan 2023-06-26 10:53:48 +03:00
parent ce8b95c2c7
commit dabc26f8a6
2 changed files with 4 additions and 3 deletions

View file

@ -148,10 +148,10 @@ class Relay:
self.connected = False
self.error_counter += 1
def _on_ping(self, _*):
def _on_ping(self, *_):
return
def _on_pong(self, _*):
def _on_pong(self, *_):
return
def _is_valid_message(self, message: str) -> bool:

View file

@ -67,7 +67,6 @@ class RelayManager:
def check_and_restart_relays(self):
stopped_relays = [r for r in self.relays.values() if r.shutdown]
for relay in stopped_relays:
logger.info(f"Restarting connection to relay '{relay.url}'")
self._restart_relay(relay)
@ -99,6 +98,8 @@ class RelayManager:
def _restart_relay(self, relay: Relay):
if relay.error_threshold_reached:
return
logger.info(f"Restarting connection to relay '{relay.url}'")
self.remove_relay(relay.url)
new_relay = self.add_relay(relay.url)
new_relay.error_counter = relay.error_counter