diff --git a/node/consensus/data/data_clock_consensus_engine.go b/node/consensus/data/data_clock_consensus_engine.go
index eed7d7b..4d93b06 100644
--- a/node/consensus/data/data_clock_consensus_engine.go
+++ b/node/consensus/data/data_clock_consensus_engine.go
@@ -559,11 +559,6 @@ func (e *DataClockConsensusEngine) Start() <-chan error {
 				continue
 			}
 
-			if nextFrame.Timestamp < time.Now().UnixMilli()-30000 {
-				time.Sleep(1 * time.Second)
-				continue
-			}
-
 			frame = nextFrame
 			_, triesAtFrame, err := e.clockStore.GetDataClockFrame(
 				e.filter,
diff --git a/node/consensus/data/main_data_loop.go b/node/consensus/data/main_data_loop.go
index c32f540..514c4a7 100644
--- a/node/consensus/data/main_data_loop.go
+++ b/node/consensus/data/main_data_loop.go
@@ -92,6 +92,9 @@ func (e *DataClockConsensusEngine) processFrame(
 	if e.latestFrameReceived < latestFrame.FrameNumber {
 		e.latestFrameReceived = latestFrame.FrameNumber
 	}
+	e.frameProverTriesMx.Lock()
+	e.frameProverTries = e.dataTimeReel.GetFrameProverTries()
+	e.frameProverTriesMx.Unlock()
 
 	trie := e.GetFrameProverTries()[0]
 	selBI, _ := dataFrame.GetSelector()
@@ -118,8 +121,7 @@ func (e *DataClockConsensusEngine) processFrame(
 
 		return nextFrame
 	} else {
-		e.announcedJoin++
-		if e.announcedJoin < 5 && !e.IsInProverTrie(e.pubSub.GetPeerID()) &&
+		if !e.IsInProverTrie(e.pubSub.GetPeerID()) &&
 			dataFrame.Timestamp > time.Now().UnixMilli()-30000 {
 			e.logger.Info("announcing prover join")
 			e.announceProverJoin()