Merge pull request #1475 from yershalom/master

[Cassnadra] Added set_keyspace for easier query cassandra
getredash · Dec 20, 2016 · 9d579dc · 9d579dc
2 parents 94519d1 + c423832
commit 9d579dc
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(self.configuration['keyspace'])
             logger.debug("Cassandra running query: %s", query)
             result = session.execute(query)