import abc
import os
from pkg_resources import DistributionNotFound, get_distribution
from six.moves.configparser import SafeConfigParser
from six import add_metaclass
from . import log_utils
try:
__version__ = get_distribution(__name__).version
except DistributionNotFound:
# package is not installed
pass
__license__ = 'Apache 2.0'
PACKAGE_DIR = os.path.dirname(os.path.abspath(__file__))
# Read the configuration files
_cfgs = ('worker.dist.cfg', 'worker.local.cfg')
config = SafeConfigParser({
'RABBITMQ_USER': os.environ.get('RABBITMQ_USER', 'guest'),
'RABBITMQ_PASS': os.environ.get('RABBITMQ_PASS', 'guest'),
'RABBITMQ_HOST': os.environ.get('RABBITMQ_HOST', 'localhost')
})
config.read([os.path.join(PACKAGE_DIR, f) for f in _cfgs])
# Create and configure our logger
logger = log_utils.setupLogger(config)
[docs]@add_metaclass(abc.ABCMeta)
class GirderWorkerPluginABC(object):
"""
Abstract base class for Girder Worker plugins. Plugins must descend from this
class; see the :ref:`plugins` section for more information.
"""
@abc.abstractmethod
def __init__(self, app, *args, **kwargs):
""" """
[docs] @abc.abstractmethod
def task_imports(self):
"""Plugins must override this method."""
[docs]class GirderWorkerPlugin(GirderWorkerPluginABC):
def __init__(self, app, *args, **kwargs):
self.app = app
[docs] def task_imports(self):
return ['girder_worker.tasks']