def disable(self):
        self._enabled = False
        try:
            self._client.unschedule(self)
        except __HOLE__:
            pass
dataset/ETHPy150Open dpkp/kafka-python/kafka/coordinator/consumer.py/AutoCommitTask.disable