Function decode_plan 

async fn decode_plan(
    bytes: Bytes,
    state: &SessionState,
    payload: bool,
) -> Result<LogicalPlan>

Decode with async MergeScan handling, preserving the default consumer’s extension checks.