Added set_keyspace for easier query cassandra

getredash · Dec 20, 2016 · 0248371 · 0248371
1 parent a860c83
commit 0248371
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/redash/query_runner/cass.py b/redash/query_runner/cass.py
@@ -72,6 +72,7 @@ def run_query(self, query, user):
                 connection = Cluster([self.configuration.get('host', '')])
 
             session = connection.connect()
+            session.set_keyspace('{}'.format(self.configuration['keyspace']))
             logger.debug("Cassandra running query: %s", query)
             result = session.execute(query)