Use six.reraise for proper py3k compatibility

2014-05-02 17:48:42 -05:00
parent 2f04c9cde1
commit 35df9c811a
1 changed files with 2 additions and 2 deletions
--- a/cassandra/concurrent.py
+++ b/cassandra/concurrent.py
@@ -86,9 +86,9 @@ def execute_concurrent(session, statements_and_parameters, concurrency=100, rais
    event.wait()
    if first_error:
        exc = first_error[0]
-        if isinstance(exc, tuple):
+        if six.PY2 and isinstance(exc, tuple):
            (exc_type, value, traceback) = exc
-            raise exc_type, value, traceback
+            six.reraise(exc_type, value, traceback)
        else:
            raise exc
    else: