fix: weight aggreagator not pushing subnet data + use netuid 2 on mod…

…ule fetcher
renlabs-dev · Oct 14, 2024 · 09e4fd5 · 09e4fd5
1 parent b6ccf0d
commit 09e4fd5
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/apps/commune-worker/src/common/index.ts b/apps/commune-worker/src/common/index.ts
@@ -23,7 +23,9 @@ export interface WorkerProps {
 
 // -- Constants -- //
 
-export const CONSENSUS_NETUID = 0;
+export const SUBNETS_NETUID = 0
+export const CONSENSUS_NETUID = 2;
+
 export const BLOCK_TIME = 8000;
 export const DAO_EXPIRATION_TIME = 75600; // 7 days in blocks
 

diff --git a/apps/commune-worker/src/workers/weight-aggregator.ts b/apps/commune-worker/src/workers/weight-aggregator.ts
@@ -27,8 +27,7 @@ import {
   normalizeWeightsToPercent,
 } from "../weights";
 
-const SUBNETS_NETUID = 0;
-const MODULES_NETUID = 2;
+import { SUBNETS_NETUID, CONSENSUS_NETUID } from "../common";
 
 type AggregatorKind = "module" | "subnet";
 
@@ -219,7 +218,7 @@ async function postModuleAggregation(
   await doVote(
     api,
     keypair,
-    MODULES_NETUID,
+    CONSENSUS_NETUID,
     normalizedWeights,
   );
 }
@@ -237,7 +236,7 @@ async function postSubnetAggregation(
     subnetWeightMap,
   );
 
-  const subnetWeights: SubnetWeight[] = Array.from(
+  const dbSubnetWeights: SubnetWeight[] = Array.from(
     stakeWeights,
   )
     .map(([netuid, stakeWeight]): SubnetWeight | null => {
@@ -255,6 +254,8 @@ async function postSubnetAggregation(
     })
     .filter((subnet) => subnet !== null);
 
+  await insertSubnetWeight(dbSubnetWeights);
+
   await doVote(
     api,
     keypair,