Source code for biothings.hub.dataplugin.manager

import asyncio

from biothings.utils.hub_db import get_data_plugin
import biothings.hub.dataload.dumper as dumper


[docs]class GitDataPlugin(dumper.GitDumper): # override to point to "data_plugin" collection instead of src_dump # so we don't mix data sources and plugins def prepare_src_dump(self): self.src_dump = get_data_plugin() self.src_doc = self.src_dump.find_one({'_id': self.src_name}) or {}
[docs]class ManualDataPlugin(dumper.ManualDumper): # override to point to "data_plugin" collection instead of src_dump # so we don't mix data sources and plugins def prepare_src_dump(self): self.src_dump = get_data_plugin() self.src_doc = self.src_dump.find_one({'_id': self.src_name}) or {}
[docs] @asyncio.coroutine def dump(self, *args, **kwargs): yield from super(ManualDataPlugin, self).dump( path="", # it's the version is original method implemention # but no version here available release="", *args, **kwargs)
[docs]class DataPluginManager(dumper.DumperManager): def load(self, plugin_name, *args, **kwargs): return super(DataPluginManager, self).dump_src(plugin_name, *args, **kwargs)