Function local_execute 

pub async fn local_execute(
    session: Arc<SessionImpl>,
    query: Query,
    can_timeout_cancel: bool,
) -> Result<ReceiverStream<Result<DataChunk, BoxedError>>>