fix: pass consistency to connection setup

hipagesgroup · Jun 9, 2022 · 43dd91b · 43dd91b
1 parent ae0d965
commit 43dd91b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/hip_data_tools/apache/cassandra.py b/hip_data_tools/apache/cassandra.py
@@ -251,6 +251,7 @@ def setup_connection(self, default_keyspace) -> None:
             self._settings.cluster_ips,
             load_balancing_policy=self._settings.load_balancing_policy,
             auth_provider=self._auth,
+            consistency=self.consistency_level,
             port=self._settings.port,
             ssl_options=self._settings.ssl_options,
             default_keyspace=default_keyspace)