'Set the default keyspace for all queries made through this Session.
This operation blocks until complete.'

def set_keyspace(self, keyspace):

    self.execute(('USE    %s' % (protect_name(keyspace),)))
