def lease_lost()

in consumer/record_processor.py [0:0]


    def lease_lost(self, lease_lost_input):
        logging.warn("Lease has been lost")