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