Wait until block is processed before sending columns for processing

This commit is contained in:
Pawan Dhananjay
2026-06-09 17:57:00 -07:00
parent d797275fae
commit ffc5e47ad1

View File

@@ -412,9 +412,10 @@ impl<T: BeaconChainTypes> SingleBlockLookup<T> {
state.maybe_start_downloading(|| { state.maybe_start_downloading(|| {
cx.custody_lookup_request(self.id, self.block_root, *slot, peers.clone()) cx.custody_lookup_request(self.id, self.block_root, *slot, peers.clone())
})?; })?;
// Wait for the parent to be imported, data column processing result handle does // Wait for the current block and parent to be imported, data column processing result handle does
// not support `ParentUnknown`. // not support `ParentUnknown`.
if self.awaiting_parent.is_none() if self.block_request.state.is_processed()
&& self.awaiting_parent.is_none()
&& let Some(data) = state.maybe_start_processing() && let Some(data) = state.maybe_start_processing()
{ {
cx.send_custody_columns_for_processing( cx.send_custody_columns_for_processing(