Struct BuildTask

pub struct BuildTask {
    pub engine: Arc<EngineClient>,
    pub cfg: Arc<RollupConfig>,
    pub attributes: OpAttributesWithParent,
    pub is_attributes_derived: bool,
    pub payload_tx: Option<Sender<OpExecutionPayloadEnvelope>>,
}

Task for building new blocks with automatic forkchoice synchronization.

The BuildTask handles the complete block building workflow, including:

1. Automatic Forkchoice Updates: Performs initial engine_forkchoiceUpdated call with payload attributes to initiate block building on the execution layer
2. Payload Construction: Retrieves the built payload using engine_getPayload
3. Block Import: Imports the payload using InsertTask for canonicalization

Forkchoice Integration

Unlike previous versions where forkchoice updates required separate tasks, BuildTask now handles forkchoice synchronization automatically as part of the block building process. This eliminates the need for explicit forkchoice management and ensures atomic block building operations.

Error Handling

The task uses EngineBuildError for build-specific failures during the forkchoice update phase, and delegates to InsertTaskError for payload import failures.

Fields

engine: Arc<EngineClient>

The engine API client.

cfg: Arc<RollupConfig>

The RollupConfig.

attributes: OpAttributesWithParent

The OpAttributesWithParent to instruct the execution layer to build.

is_attributes_derived: bool

Whether or not the payload was derived, or created by the sequencer.

payload_tx: Option<Sender<OpExecutionPayloadEnvelope>>

An optional channel to send the built OpExecutionPayloadEnvelope to, after the block has been built, imported, and canonicalized.

Implementations

impl BuildTask

pub const fn new( engine: Arc<EngineClient>, cfg: Arc<RollupConfig>, attributes: OpAttributesWithParent, is_attributes_derived: bool, payload_tx: Option<Sender<OpExecutionPayloadEnvelope>>, ) -> Self

Creates a new block building task.

Trait Implementations

impl Clone for BuildTask

fn clone(&self) -> BuildTask

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BuildTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EngineTaskExt for BuildTask

type Output = ()

The output type of the task.

type Error = BuildTaskError

The error type of the task.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 mut EngineState, ) -> Pin<Box<dyn Future<Output = Result<(), BuildTaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the task, taking a shared lock on the engine state and self.