public Map<String, QualifiedDataSourceState> loadStates() {
        Collection<String> qualifiedDataSourceNodes = repository.getChildrenKeys(QualifiedDataSourceNode.getRootPath());
        Map<String, QualifiedDataSourceState> result = new HashMap<>(qualifiedDataSourceNodes.size(), 1F);
        qualifiedDataSourceNodes.forEach(each -> {
            String yamlContent = repository.query(QualifiedDataSourceNode.getQualifiedDataSourceNodePath(new QualifiedDataSource(each)));
            if (!Strings.isNullOrEmpty(yamlContent)) {
                result.put(each, new YamlQualifiedDataSourceStateSwapper().swapToObject(YamlEngine.unmarshal(yamlContent, YamlQualifiedDataSourceState.class)));
            }
        });
        return result;
    }
@Test
    void assertLoadStatus() {
        List<String> disabledDataSources = Arrays.asList("replica_query_db.readwrite_ds.replica_ds_0", "other_schema.other_ds.other_ds0");
        when(repository.getChildrenKeys(anyString())).thenReturn(disabledDataSources);
        assertDoesNotThrow(() -> new QualifiedDataSourceStatePersistService(repository).loadStates());
    }