def schedule_unique(self, delay, fn, *args, **kwargs):
        task = (fn, args, tuple(kwargs.items()))
        if self._scheduled_tasks not in task:
            self._insert_task(delay, task)
        else:
            log.debug("Ignoring schedule_unique for already-scheduled task: %r", task)
dataset/ETHPy150Open datastax/python-driver/cassandra/cluster.py/_Scheduler.schedule_unique/swapped operands of `not in`