Develop (#113)

* Rework auto restart (#111)

* run validtor with no thread

* remove should exit in except

* remove log that causes errors

* Shuffle miners (#110)

* wordings

* shuffle miners globally

* CI: trigger on PR on develop

Author: Thykof

.github/workflows/ci.yaml

@@ -7,6 +7,7 @@ on:
   pull_request:
     branches:
       - main
+      - develop
 
 jobs:
   ci:

neurons/validator.py

@@ -102,7 +102,4 @@ async def forward(self):
 
 # The main function parses the configuration and runs the validator.
 if __name__ == "__main__":
-    with Validator() as validator:
-        while not validator.should_exit:
-            bt.logging.info(f"Validator running... {time.time()}")
-            time.sleep(600)
+    Validator().run()

synth/base/validator.py

@@ -138,8 +138,6 @@ def run(self):
         # This loop maintains the validator's operations until intentionally stopped.
         try:
             while True:
-                bt.logging.info(f"step({self.step}) block({self.block})")
-
                 # Run multiple forwards concurrently.
                 self.loop.run_until_complete(self.concurrent_forward())
 
@@ -164,8 +162,6 @@ def run(self):
             bt.logging.debug(
                 str(print_exception(type(err), err, err.__traceback__))
             )
-            bt.logging.debug("Scheduling validator to stop.")
-            self.should_exit = True
 
     def run_in_background_thread(self):
         """

synth/utils/logging.py

@@ -51,7 +51,7 @@ def emit(self, record):
                     )
             except Exception as err:
                 bt.logging.warning(
-                    f"Error occurred while sending alert to wandb: ---{str(err)}--- then message: ---{log_entry}---"
+                    f"Error occurred while sending alert to wandb: ---{str(err)}--- the message: ---{log_entry}---"
                 )
                 bt.logging.warning(
                     str(print_exception(type(err), err, err.__traceback__))

synth/validator/forward.py

@@ -378,6 +378,8 @@ def _get_available_miners_and_update_metagraph_history(
     if len(metagraph_info) > 0:
         miner_data_handler.update_metagraph_history(metagraph_info)
 
+    random.shuffle(miner_uids)
+
     return miner_uids