(self, parser)
| 161 | raise ValueError("Unknown schema target_type: '%s'" % target_type) |
| 162 | |
| 163 | def _rebuild_all(self, parser): |
| 164 | current_keyspaces = set() |
| 165 | for keyspace_meta in parser.get_all_keyspaces(): |
| 166 | current_keyspaces.add(keyspace_meta.name) |
| 167 | old_keyspace_meta = self.keyspaces.get(keyspace_meta.name, None) |
| 168 | self.keyspaces[keyspace_meta.name] = keyspace_meta |
| 169 | if old_keyspace_meta: |
| 170 | self._keyspace_updated(keyspace_meta.name) |
| 171 | else: |
| 172 | self._keyspace_added(keyspace_meta.name) |
| 173 | |
| 174 | # remove not-just-added keyspaces |
| 175 | removed_keyspaces = [name for name in self.keyspaces.keys() |
| 176 | if name not in current_keyspaces] |
| 177 | self.keyspaces = dict((name, meta) for name, meta in self.keyspaces.items() |
| 178 | if name in current_keyspaces) |
| 179 | for ksname in removed_keyspaces: |
| 180 | self._keyspace_removed(ksname) |
| 181 | |
| 182 | def _update_keyspace(self, keyspace_meta, new_user_types=None): |
| 183 | ks_name = keyspace_meta.name |
no test coverage detected