def add_plugin_collection()

in collection_manager/collection_manager/services/CollectionProcessor.py [0:0]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    def add_plugin_collection(self, collection: Collection):
        history_manager = self._get_history_manager(None)

        if isinstance(history_manager, SolrIngestionHistory):
            collection_config = {
                'path': collection.path,
                'config': collection.config
            }

            collection_dimensions = dict(collection.dimension_names)

            collection_config['config']['variables'] = collection_dimensions['variable']
            collection_config['config']['coords'] = {dim: collection_dimensions[dim]
                                                     for dim in collection_dimensions if dim != 'variable'}

            history_manager._push_dataset(collection.dataset_id, collection.store_type, json.dumps(collection_config))