diff --git a/example.py b/example.py
index 86ac9eaa42..61a51f1ae0 100755
--- a/example.py
+++ b/example.py
@@ -18,7 +18,7 @@ def main():
     cluster = Cluster(['127.0.0.1'])
     session = cluster.connect()
 
-    rows = session.execute("SELECT keyspace_name FROM system.schema_keyspaces")
+    rows = session.execute("SELECT keyspace_name FROM system_schema.keyspaces")
     if KEYSPACE in [row[0] for row in rows]:
         log.info("dropping existing keyspace...")
         session.execute("DROP KEYSPACE " + KEYSPACE)