def handle_finish(self, conn, message_id):
        self.logger.debug('[%s] finished message: %s' % (conn, message_id))
        self.handle_backoff(False)
        self.update_ready(conn)
        self.on_finish.send(self, message_id=message_id)
dataset/ETHPy150Open wtolson/gnsq/gnsq/reader.py/Reader.handle_finish/original