Merge pull request #245 from blockchain-insights/feat/upgrade2.2_bt7.0

Updating to bittensor 7.0

insights/api/insight_api.py

@@ -10,6 +10,7 @@
 import yaml
 
 import numpy as np
+from typing import List, Dict, Tuple, Union, Any
 from protocols.chat import ChatMessageRequest, ChatMessageResponse, ChatMessageVariantRequest, ContentType
 from fastapi.middleware.cors import CORSMiddleware
 from starlette.requests import Request
@@ -154,7 +155,6 @@ def __init__(
             wallet: None,
             subtensor: None,
             metagraph: None,
-            scores: None,
         ):
         """
         API can be invoked while running a validator.

neurons/validators/utils/uids.py

@@ -37,9 +37,11 @@ def check_uid_availability(
     # Available otherwise.
     return True
 
-def get_top_miner_uids(
-    metagraph: "bt.metagraph.Metagraph", top_rate: float = 1, exclude: List[int] = None, vpermit_tao_limit: int = 4096
-) -> np.int64:
+async def get_top_miner_uids(metagraph: "bt.metagraph.Metagraph",
+                             wallet: "bt.wallet.Wallet",
+                             top_rate: float = 1,
+                             vpermit_tao_limit: int = 4096) -> np.int64:
+
     """Returns the available top miner UID from the metagraph.
     Args:
         metagraph (bt.metagraph.Metagraph): Metagraph object
@@ -50,9 +52,8 @@ def get_top_miner_uids(
     Returns:
         top_miner_uid (np.int64): The top miner UID.
     """
-
-    dendrite = bt.dendrite(wallet=wallet)
     try:
+        dendrite = bt.dendrite(wallet=wallet)
         miner_candidate_uids = []
         for uid in range(metagraph.n.item()):
             uid_is_available = check_uid_availability(
@@ -73,22 +74,15 @@ def get_top_miner_uids(
 
         # Consider both of incentive and trust score
         values = [(uid, metagraph.I[uid] * metagraph.trust[uid]) for uid in miner_ip_filtered_uids]
-
-        # Consider only incentive
-        # values = [(uid, metagraph.I[uid]) for uid in candidate_uids]
-
-    ips = []
-    filtered_uids = []
-    for uid, _ in sorted_values:
-        if metagraph.axons[uid].ip not in ips:
-            ips.append(metagraph.axons[uid].ip)
-            filtered_uids.append(uid)
-
-    values = [(uid, metagraph.I[uid] * metagraph.trust[uid]) for uid in filtered_uids]
-    sorted_values = sorted(values, key=lambda x: x[1], reverse=True)
-    top_rate_num_items = max(1, int(top_rate * len(filtered_uids)))
-    top_miner_uids = np.array([uid for uid, _ in sorted_values[:top_rate_num_items]])
-    return top_miner_uids
+        sorted_values = sorted(values, key=lambda x: x[1], reverse=True)
+        top_rate_num_items = max(1, int(top_rate * len(miner_ip_filtered_uids)))
+        top_miner_uids = np.array([uid for uid, _ in sorted_values[:top_rate_num_items]])
+        return top_miner_uids
+    except Exception as e:
+        logger.error(message=f"Failed to get top miner uids: {e}")
+        return None
+    finally:
+        dendrite.close_session()
 
 
 def get_random_uids(