def shutdown_requested()

in consumer/record_processor.py [0:0]

• 3 lines of code
• 1 McCabe index (conditional complexity)

    def shutdown_requested(self, shutdown_requested_input):
        logging.warn("Shutdown has been requested, checkpointing.")
        shutdown_requested_input.checkpointer.checkpoint()