

@inlineCallbacks
def shutdown(self):
    LOGGER.debug('Closting connection')
    try:
        self.enqueueCallLater.cancel()
    except:
        pass
    LOGGER.info('Closing broker connection')
    (yield self.chan.channel_close())
    chan0 = (yield self.conn.channel(0))
    (yield chan0.connection_close())
    LOGGER.info('Closing MYSQL Connnection Pool')
    (yield self.mysql.close())

dataset/ETHPy150Open wehriam/awspider/awspider/servers2/scheduler.py SchedulerServer.shutdown/original