From f2a3bd2d8ecde102e52d94375449bf62a618901a Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Fri, 22 Nov 2024 01:52:36 -0600 Subject: [PATCH] don't try to make workers run if they aren't in ready state --- node/consensus/data/data_clock_consensus_engine.go | 3 +++ node/consensus/data/main_data_loop.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/node/consensus/data/data_clock_consensus_engine.go b/node/consensus/data/data_clock_consensus_engine.go index 4ffa4c7..426efea 100644 --- a/node/consensus/data/data_clock_consensus_engine.go +++ b/node/consensus/data/data_clock_consensus_engine.go @@ -563,6 +563,9 @@ func (e *DataClockConsensusEngine) PerformTimeProof( }) } } + if len(actives) < 3 { + return []mt.DataBlock{} + } output := make([]mt.DataBlock, len(actives)) e.logger.Info( "creating data shard ring proof", diff --git a/node/consensus/data/main_data_loop.go b/node/consensus/data/main_data_loop.go index 195c9fa..8285e45 100644 --- a/node/consensus/data/main_data_loop.go +++ b/node/consensus/data/main_data_loop.go @@ -292,7 +292,7 @@ func (e *DataClockConsensusEngine) processFrame( outputs := e.PerformTimeProof(latestFrame, latestFrame.Difficulty, ring) if outputs == nil || len(outputs) < 3 { - e.logger.Error("could not successfully build proof, reattempting") + e.logger.Info("workers not yet available for proving") return latestFrame } modulo := len(outputs)