code: def clear(self):
          
  
          if not self.connected:
              raise QueueNotConnectedError("Queue is not Connected")
  
          self.__db.delete(self._key)
          self.__db.delete(self._lock_key)
docs: Clear all Tasks in the queue.