diff --git a/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py b/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py index b8b1e19da..e385c75de 100644 --- a/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py +++ b/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py @@ -77,6 +77,12 @@ async def connect(self): ): msg = f"Inactive validator: {self.validator_key}" fail = True + validator_blacklisted = await ValidatorBlacklist.objects.filter( + validator=self.validator + ).aexists() + if validator_blacklisted: + msg = f"Blacklisted validator: {self.validator_key}" + fail = True if fail: await self.send(miner_requests.GenericError(details=msg).model_dump_json()) logger.info(msg)