Merge pull request #144 from web-genie-ai/hotfix/thread-issue

hotfix: resolve thread issue

Author: sangar-1028

neurons/validators/genie_validator.py

@@ -50,7 +50,7 @@
 class GenieValidator:
     def __init__(self, neuron: BaseNeuron):
         self.neuron = neuron
-        self.lock = threading.Lock()
+        self.lock = self.neuron.lock
         self.config = neuron.config
         self.miner_results = []
         self.synthetic_tasks = []

neurons/validators/score_manager.py

@@ -22,7 +22,7 @@ class ScoreManager:
     def __init__(self, neuron: BaseNeuron):
         self.neuron = neuron
         self.state_path = self.neuron.config.neuron.full_path + "/state.npz"
-        self.lock = threading.Lock()
+        self.lock = self.neuron.lock
 
         self.hotkeys = copy.deepcopy(self.neuron.metagraph.hotkeys)
         self.current_session = -1

neurons/validators/validator.py

@@ -69,7 +69,7 @@ def __init__(self, config=None):
         self.query_miners_thread: Union[threading.Thread, None] = None
         self.score_thread: Union[threading.Thread, None] = None
         self.sync_thread: Union[threading.Thread, None] = None
-        self.lock = threading.Lock()
+        self.lock = threading.RLock()
 
         self.genie_validator = GenieValidator(neuron=self)
         self.score_manager = ScoreManager(neuron=self)