

def __init__(self, **kw):
    super(NotabeneHandler, self).__init__(**kw)
    global connection_manager
    self.queue_name = kw.get('queue_name')
    if (self.queue_name is None):
        raise NotabeneException("No 'queue_name' provided")
    (self.connection, self.exchange) = connection_manager.get_connection(kw, self.queue_name)
    self.env_keys = kw.get('env_keys', [])

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py NotabeneHandler.__init__/original