diff --git a/miners/miner_factory.py b/miners/miner_factory.py index e09525d6..89a38b9c 100644 --- a/miners/miner_factory.py +++ b/miners/miner_factory.py @@ -33,6 +33,9 @@ class MinerFactory: self.miners[ip] = miner return miner + def clear_cached_miners(self): + self.miners = {} + @staticmethod async def _get_version_data(ip: ipaddress.ip_address) -> dict or None: for i in range(3): diff --git a/network/__init__.py b/network/__init__.py index 1e5870a9..9dc261d1 100644 --- a/network/__init__.py +++ b/network/__init__.py @@ -43,6 +43,7 @@ class MinerNetwork: miner_ips = list(filter(None, miner_ips)) print(f"Found {len(miner_ips)} connected miners...") create_miners_tasks = [] + self.miner_factory.clear_cached_miners() for miner_ip in miner_ips: create_miners_tasks.append(self.miner_factory.get_miner(miner_ip)) miners = await asyncio.gather(*create_miners_tasks)