diff --git a/cassandra/cqlengine/connection.py b/cassandra/cqlengine/connection.py index 100e8d5a..5673caf4 100644 --- a/cassandra/cqlengine/connection.py +++ b/cassandra/cqlengine/connection.py @@ -184,6 +184,8 @@ def register_connection(name, hosts=None, consistency=None, lazy_connect=False, conn = Connection.from_session(name, session=session) conn.setup_session() else: # use hosts argument + if consistency is None: + consistency = ConsistencyLevel.LOCAL_ONE conn = Connection( name, hosts=hosts, consistency=consistency, lazy_connect=lazy_connect,