def resume_writing(self): logging.warn("PEER PROTOCL IS DRAINED BELOW THE HIGH-WATER MARK") self._throttle = False