diff --git a/beacon_chain/consensus_object_pools/data_column_quarantine.nim b/beacon_chain/consensus_object_pools/data_column_quarantine.nim
index 4f322e0e3..f639973ff 100644
--- a/beacon_chain/consensus_object_pools/data_column_quarantine.nim
+++ b/beacon_chain/consensus_object_pools/data_column_quarantine.nim
@@ -131,7 +131,7 @@ func hasMissingDataColumns*(quarantine: DataColumnQuarantine,
                           max(SAMPLES_PER_SLOT.uint64,
                               localSubnetCount))
   for i in localCustodyColumns:
-    if (blck.root, ColumnIndex i) notin quarantine.data_columns and 
+    if (blck.root, ColumnIndex i) in quarantine.data_columns and 
         len(blck.message.body.blob_kzg_commitments) != 0:
       inc counter
   if quarantine.supernode and counter == NUMBER_OF_COLUMNS:
diff --git a/beacon_chain/gossip_processing/eth2_processor.nim b/beacon_chain/gossip_processing/eth2_processor.nim
index 95a2b5735..76dcca346 100644
--- a/beacon_chain/gossip_processing/eth2_processor.nim
+++ b/beacon_chain/gossip_processing/eth2_processor.nim
@@ -406,7 +406,7 @@ proc processDataColumnSidecar*(
         elif self.dataColumnQuarantine[].hasEnoughDataColumns(forkyBlck):
           let
             columns = self.dataColumnQuarantine[].gatherDataColumns(forkyBlck)
-          if columns.len >= (NUMBER_OF_COLUMNS div 2):
+          if columns.len >= (NUMBER_OF_COLUMNS div 2) and quarantine.supernode:
             let
               reconstructed_columns = 
                 self.processReconstructionFromGossip(forkyBlck, columns)