Init

Author: thewhaleking

bittensor/core/async_subtensor.py

@@ -15,6 +15,7 @@
 from scalecodec.type_registry import load_type_registry_preset
 
 from bittensor.core.types import SubtensorMixin
+from bittensor.core.subtensor_plugins.subtensor_module import SubtensorModule
 from bittensor.core.chain_data import (
     DelegateInfo,
     StakeInfo,
@@ -131,6 +132,7 @@ def __init__(
             logging.info(
                 f"Connected to {self.network} network and {self.chain_endpoint}."
             )
+        self.subtensor_module = SubtensorModule(self)
 
     async def close(self):
         """Close the connection."""

bittensor/core/subtensor.py

@@ -13,6 +13,7 @@
 from scalecodec.type_registry import load_type_registry_preset
 
 from bittensor.core.types import SubtensorMixin
+from bittensor.core.subtensor_plugins.subtensor_module import SubtensorModule
 from bittensor.core.chain_data import (
     custom_rpc_type_registry,
     decode_account_id,
@@ -130,6 +131,7 @@ def __init__(
             logging.info(
                 f"Connected to {self.network} network and {self.chain_endpoint}."
             )
+        self.subtensor_module = SubtensorModule(self)
 
     def close(self):
         """

bittensor/core/subtensor_plugins/subtensor_module.py

@@ -0,0 +1,25 @@
+
+from typing import Union, TYPE_CHECKING
+
+
+if TYPE_CHECKING:
+    from bittensor.core.subtensor import Subtensor
+    from bittensor.core.async_subtensor import AsyncSubtensor
+
+
+class SubtensorModule:
+    def __init__(self, subtensor: Union["Subtensor", "AsyncSubtensor"]):
+        self._subtensor = subtensor
+
+    def tempo(self, netuid: int):
+        return self._subtensor.substrate.query(
+            module="SubtensorModule",
+            storage_function="Tempo",
+            params=[netuid]
+        )
+
+    def tempos(self):
+        return self._subtensor.substrate.query_map(
+            module="SubtensorModule",
+            storage_function="Tempo",
+        )