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