Source code for girder_worker

import abc
import os
from . import log_utils
from six.moves.configparser import SafeConfigParser

__version__ = '0.3.1'
__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]class GirderWorkerPluginABC(object): """ """ __metaclass__ = abc.ABCMeta @abc.abstractmethod def __init__(self, app, *args, **kwargs): """ """
[docs] @abc.abstractmethod def task_imports(self): """ """
class GirderWorkerPlugin(GirderWorkerPluginABC): def __init__(self, app, *args, **kwargs): self.app = app def task_imports(self): return ['girder_worker.tasks']