add CDCWriteException

Josh McKenzie · mambocab · commit d94cece1be22 · 2017-10-09T10:49:01.000-04:00
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -37,6 +37,7 @@ Features
 --------
 * Add idle_heartbeat_timeout cluster option to tune how long to wait for heartbeat responses. (PYTHON-762)
 * Add HostFilterPolicy (PYTHON-761)
+* Add new exception type for CDC (PYTHON-837)
 
 Bug Fixes
 ---------
diff --git a/cassandra/__init__.py b/cassandra/__init__.py
@@ -387,6 +387,14 @@ def __init__(self, message, write_type=None, **kwargs):
         self.write_type = write_type
 
 
+class CDCWriteFailure(RequestExecutionException):
+    """
+    Hit limit on data in CDC folder, writes are rejected
+    """
+    def __init__(self, message):
+        Exception.__init__(self, message)
+
+
 class CoordinationFailure(RequestExecutionException):
     """
     Replicas sent a failure to the coordinator.
diff --git a/cassandra/protocol.py b/cassandra/protocol.py
@@ -331,6 +331,11 @@ def to_exception(self):
         return WriteFailure(self.summary_msg(), **self.info)
 
 
+class CDCWriteException(RequestExecutionException):
+    summary = 'Failed to execute write due to CDC space exhaustion.'
+    error_code = 0x1600
+
+
 class SyntaxException(RequestValidationException):
     summary = 'Syntax error in CQL query'
     error_code = 0x2000
diff --git a/docs/api/cassandra.rst b/docs/api/cassandra.rst
@@ -31,6 +31,9 @@
 .. autoexception:: RequestExecutionException()
    :members:
 
+.. autoexception:: CDCWriteException()
+   :members:
+
 .. autoexception:: Unavailable()
    :members:
 
