diff --git a/beacon_chain/consensus_object_pools/data_column_quarantine.nim b/beacon_chain/consensus_object_pools/data_column_quarantine.nim index 89aba2816..1fd8a67ee 100644 --- a/beacon_chain/consensus_object_pools/data_column_quarantine.nim +++ b/beacon_chain/consensus_object_pools/data_column_quarantine.nim @@ -96,10 +96,9 @@ func hasDataColumns*(quarantine: DataColumnQuarantine, quarantine.data_columns.hasKey( (blck.root, idx)): inc counter - if counter > 1: - return true - else: + if counter == 0: return false + true func dataColumnFetchRecord*(quarantine: DataColumnQuarantine, blck: deneb.SignedBeaconBlock | electra.SignedBeaconBlock): DataColumnFetchRecord = diff --git a/beacon_chain/nimbus_beacon_node.nim b/beacon_chain/nimbus_beacon_node.nim index a7b542f8e..8847b80e0 100644 --- a/beacon_chain/nimbus_beacon_node.nim +++ b/beacon_chain/nimbus_beacon_node.nim @@ -427,9 +427,7 @@ proc initFullNode( # maybeFinalized = maybeFinalized) when consensusFork >= ConsensusFork.Deneb: - if not dataColumnQuarantine[].hasDataColumns(forkyBlck): - # We don't have all the data columns for this block, so we have - # to put it in columnless quarantine. + if len(forkyBlck.message.body.blob_kzg_commitments) != 0: if not quarantine[].addColumnless(dag.finalizedHead.slot, forkyBlck): err(VerifierError.UnviableFork) else: