Merge pull request #722 from opentensor/increment-blocks-since-last-step

 Increment blocks since last step in coinbase

Author: unconst

pallets/subtensor/src/coinbase/run_coinbase.rs

@@ -131,6 +131,11 @@ impl<T: Config> Pallet<T> {
                     log::debug!("Accumulated emissions on hotkey {:?} for netuid {:?}: mining {:?}, validator {:?}", hotkey, *netuid, mining_emission, validator_emission);
                 }
             } else {
+                // No epoch, increase blocks since last step and continue
+                Self::set_blocks_since_last_step(
+                    *netuid,
+                    Self::get_blocks_since_last_step(*netuid).saturating_add(1),
+                );
                 log::debug!("Tempo not reached for subnet: {:?}", *netuid);
             }
         }

pallets/subtensor/tests/epoch.rs

@@ -2703,6 +2703,53 @@ fn test_get_set_alpha() {
     });
 }
 
+#[test]
+fn test_blocks_since_last_step() {
+    new_test_ext(1).execute_with(|| {
+        System::set_block_number(0);
+
+        let netuid: u16 = 1;
+        let tempo: u16 = 7200;
+        add_network(netuid, tempo, 0);
+
+        let original_blocks: u64 = SubtensorModule::get_blocks_since_last_step(netuid);
+
+        step_block(5);
+
+        let new_blocks: u64 = SubtensorModule::get_blocks_since_last_step(netuid);
+
+        assert!(new_blocks > original_blocks);
+        assert_eq!(new_blocks, 5);
+
+        let blocks_to_step: u16 = SubtensorModule::blocks_until_next_epoch(
+            netuid,
+            tempo,
+            SubtensorModule::get_current_block_as_u64(),
+        ) as u16
+            + 10;
+        step_block(blocks_to_step);
+
+        let post_blocks: u64 = SubtensorModule::get_blocks_since_last_step(netuid);
+
+        assert_eq!(post_blocks, 10);
+
+        let blocks_to_step: u16 = SubtensorModule::blocks_until_next_epoch(
+            netuid,
+            tempo,
+            SubtensorModule::get_current_block_as_u64(),
+        ) as u16
+            + 20;
+        step_block(blocks_to_step);
+
+        let new_post_blocks: u64 = SubtensorModule::get_blocks_since_last_step(netuid);
+
+        assert_eq!(new_post_blocks, 20);
+
+        step_block(7);
+
+        assert_eq!(SubtensorModule::get_blocks_since_last_step(netuid), 27);
+    });
+}
 // // Map the retention graph for consensus guarantees with an single epoch on a graph with 512 nodes, of which the first 64 are validators, the graph is split into a major and minor set, each setting specific weight on itself and the complement on the other.
 // //
 // // ```import torch