openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Handle Unauthorized message on schema_triggers query

Browse Source 
For PYTHON-155, workaround CASSANDRA-7967
This commit is contained in:
Adam Holmberg
2014-09-18 10:38:40 -05:00
parent 32d1cf78e7
commit 3211e8b0be
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cassandra/cluster.py
View File

@@ -42,7 +42,8 @@ from functools import partial, wraps
from itertools import groupby from itertools import groupby
from cassandra import (ConsistencyLevel, AuthenticationFailed, from cassandra import (ConsistencyLevel, AuthenticationFailed,
InvalidRequest, OperationTimedOut, UnsupportedOperation) InvalidRequest, OperationTimedOut,
UnsupportedOperation, Unauthorized)
from cassandra.connection import ConnectionException, ConnectionShutdown from cassandra.connection import ConnectionException, ConnectionShutdown
from cassandra.encoder import Encoder from cassandra.encoder import Encoder
from cassandra.protocol import (QueryMessage, ResultMessage, from cassandra.protocol import (QueryMessage, ResultMessage,
@@ -1970,6 +1971,10 @@ class ControlConnection(object):
if isinstance(triggers_result, InvalidRequest): if isinstance(triggers_result, InvalidRequest):
log.debug("[control connection] triggers table not found") log.debug("[control connection] triggers table not found")
triggers_result = {} triggers_result = {}
elif isinstance(triggers_result, Unauthorized):
log.warn("[control connection] this version of Cassandra does not allow access to schema_triggers metadata with authorization enabled (CASSANDRA-7967); "
"The driver will operate normally, but will not reflect triggers in the local metadata model, or schema strings.")
triggers_result = {}
else: else:
raise triggers_result raise triggers_result