From 024837137bb253719b942104b367a7ab78fef11e Mon Sep 17 00:00:00 2001 From: syerushalmy Date: Tue, 20 Dec 2016 13:58:09 +0200 Subject: [PATCH 1/2] Added set_keyspace for easier query cassandra --- redash/query_runner/cass.py | 1 + 1 file changed, 1 insertion(+) diff --git a/redash/query_runner/cass.py b/redash/query_runner/cass.py index 08f9ce55eb..81e2d6865b 100644 --- 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) From c4238329314facc920b93f83b62ac84871bdeadf Mon Sep 17 00:00:00 2001 From: syerushalmy Date: Tue, 20 Dec 2016 14:04:15 +0200 Subject: [PATCH 2/2] Fixed python typo --- redash/query_runner/cass.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redash/query_runner/cass.py b/redash/query_runner/cass.py index 81e2d6865b..a503f6a9b6 100644 --- a/redash/query_runner/cass.py +++ b/redash/query_runner/cass.py @@ -72,7 +72,7 @@ def run_query(self, query, user): connection = Cluster([self.configuration.get('host', '')]) session = connection.connect() - session.set_keyspace('{}'.format(self.configuration['keyspace'])) + session.set_keyspace(self.configuration['keyspace']) logger.debug("Cassandra running query: %s", query) result = session.execute(query)