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