diff --git a/consensus/consensus_service.go b/consensus/consensus_service.go
index 8a676a181..ce6bf32d3 100644
--- a/consensus/consensus_service.go
+++ b/consensus/consensus_service.go
@@ -45,6 +45,10 @@ func (consensus *Consensus) GetNextRnd() ([32]byte, [32]byte, error) {
 		return [32]byte{}, [32]byte{}, errors.New("No available randomness")
 	}
 	vdfOutput := consensus.pendingRnds[0]
+
+	//pop the first vdfOutput from the list
+	consensus.pendingRnds = consensus.pendingRnds[1:]
+
 	rnd := [32]byte{}
 	blockHash := [32]byte{}
 	copy(rnd[:], vdfOutput[:32])
diff --git a/node/node_handler.go b/node/node_handler.go
index 275ccaae1..890adbaf2 100644
--- a/node/node_handler.go
+++ b/node/node_handler.go
@@ -413,13 +413,6 @@ func (node *Node) PostConsensusProcessing(newBlock *types.Block) {
 			}()
 		}
 
-		// ConfirmedBlockChannel which is listened by drand leader who will initiate DRG if its a epoch block (first block of a epoch)
-		if node.DRand != nil {
-			go func() {
-				node.ConfirmedBlockChannel <- newBlock
-			}()
-		}
-
 		// TODO: update staking information once per epoch.
 		node.UpdateStakingList(node.QueryStakeInfo())
 		node.printStakingList()