def shutdown(self):
        try:
            log.debug("Shutting down Cluster Scheduler")
        except __HOLE__:
            # this can happen on interpreter shutdown
            pass
        self.is_shutdown = True
        self._queue.put_nowait((0, 0, None))
dataset/ETHPy150Open datastax/python-driver/cassandra/cluster.py/_Scheduler.shutdown