investigate async issue

Author: eclipsevortex

subvortex/core/core_bittensor/subtensor/subtensor.py

@@ -315,7 +315,6 @@ async def watchdog():
                 prefix="ReliableSubtensor",
             )
 
-            btul.logging.info("🔁 Reinstantiating substrate connection...", prefix="ReliableSubtensor")
             await subtensor.substrate._reinstantiate_substrate()
 
             if attempt > 0:

subvortex/core/metagraph/metagraph.py

@@ -71,40 +71,40 @@ async def start(self):
         try:
             while not self.should_exit.is_set():
                 try:
-                    # # 👇 Concurrently wait for either block or shutdown
-                    # wait_block = asyncio.create_task(self.subtensor.wait_for_block())
-                    # wait_exit = asyncio.create_task(self.should_exit.wait())
-
-                    # done, pending = await asyncio.wait(
-                    #     [wait_block, wait_exit],
-                    #     timeout=12,
-                    #     return_when=asyncio.FIRST_COMPLETED,
-                    # )
-
-                    # # Cancel the other task that didn't finish
-                    # for task in pending:
-                    #     task.cancel()
-
-                    # # Exit loop if shutdown was triggered
-                    # if self.should_exit.is_set():
-                    #     break
-
-                    # # If wait_for_block() didn't complete
-                    # if wait_block not in done:
-                    #     btul.logging.warning(
-                    #         f"⏱️ Timeout after 12s while waiting for block. Retrying...",
-                    #         prefix=self.settings.logging_name,
-                    #     )
-                    #     continue
+                    # 👇 Concurrently wait for either block or shutdown
+                    wait_block = asyncio.create_task(self.subtensor.wait_for_block())
+                    wait_exit = asyncio.create_task(self.should_exit.wait())
+
+                    done, pending = await asyncio.wait(
+                        [wait_block, wait_exit],
+                        timeout=12,
+                        return_when=asyncio.FIRST_COMPLETED,
+                    )
 
-                    # if wait_block in done and not wait_block.result():
-                    #     btul.logging.warning(
-                    #         "⚠️ wait_for_block() returned False, skipping...",
-                    #         prefix=self.settings.logging_name,
-                    #     )
-                    #     continue
-                    if not await scbs.wait_for_block(subtensor=self.subtensor):
+                    # Cancel the other task that didn't finish
+                    for task in pending:
+                        task.cancel()
+
+                    # Exit loop if shutdown was triggered
+                    if self.should_exit.is_set():
+                        break
+
+                    # If wait_for_block() didn't complete
+                    if wait_block not in done:
+                        btul.logging.warning(
+                            f"⏱️ Timeout after 12s while waiting for block. Retrying...",
+                            prefix=self.settings.logging_name,
+                        )
+                        continue
+
+                    if wait_block in done and not wait_block.result():
+                        btul.logging.warning(
+                            "⚠️ wait_for_block() returned False, skipping...",
+                            prefix=self.settings.logging_name,
+                        )
                         continue
+                    # if not await scbs.wait_for_block(subtensor=self.subtensor):
+                    #     continue
 
                     block = await self.subtensor.get_current_block()
                     btul.logging.info(

subvortex/miner/metagraph/src/main.py

@@ -73,7 +73,10 @@ async def start(self):
             )
 
             # Initialize the subtensor
-            self.subtensor = btcas.AsyncSubtensor(config=config, retry_forever=True)
+            self.subtensor = btcas.AsyncSubtensor(
+                config=config,
+                retry_forever=True,
+            )
             await self.subtensor.initialize()
             btul.logging.info(str(self.subtensor))
 
@@ -132,8 +135,10 @@ async def shutdown(self):
 #     await shutdown_event.wait()
 
 import threading
+
 shutdown_complete = threading.Event()
 
+
 async def main():
     runner = Runner()
 
@@ -148,6 +153,7 @@ def _signal_handler():
     await runner.start()
     await shutdown_complete.wait()  # <--- don't exit until shutdown is complete
 
+
 async def _shutdown(runner: Runner):
     await runner.shutdown()
     shutdown_complete.set()

subvortex/miner/neuron/src/main.py

@@ -197,7 +197,9 @@ async def _initialize(self):
             MockSubtensor(self.config.netuid, wallet=self.wallet)
             if self.config.miner.mock_subtensor
             else btcas.AsyncSubtensor(
-                config=self.config, network=network, retry_forever=True
+                config=self.config,
+                network=network,
+                retry_forever=True,
             )
         )
         await self.subtensor.initialize()