def _init(self) -> None:
    self._lifecycles: Dict[(DiskType, Optional[AbstractMetadataDiskLifecycle])] = {disk_type: None for disk_type in self.DISK_TYPE_LIFECYCLE_MAP}
    self._cache = MetadataCache(self.CACHED_ATTRS, cache_path=(self.config.system.cache_dir / 'astmetad-metadata.json'))
    self._cur_disks: Dict[(DiskUUID, DiskInfo)] = {}
    self._mqtt.subscribe('astdiskd', self.handle_astdiskd_disk_info_message)
    self._requested_data: Dict[(str, str)] = {}
    self._register_request('mutate', MetadataSetManagerRequest, self.handle_mutation_request)
def _init(self) -> None:
    self._lifecycles: Dict[(DiskType, Optional[AbstractMetadataDiskLifecycle])] = {disk_type: None for disk_type in self.DISK_TYPE_LIFECYCLE_MAP}
    self._cache = MetadataCache(self.CACHED_ATTRS, cache_path=(self.config.system.cache_dir / 'astmetad-metadata.json'))
    self._cur_disks: Dict[(DiskUUID, DiskInfo)] = {}
    self._mqtt.subscribe('astdiskd', self.handle_astdiskd_disk_info_message)
    self._requested_data: Dict[(str, str)] = {}
    self._register_request('mutate', MetadataSetManagerRequest, self.handle_mutation_request)