Fix is_shutdown check when running in executor

thobbs · thobbs · commit 84682187d898 · 2014-05-28T18:37:22.000-05:00
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -1,3 +1,12 @@
+2.0.1
+=====
+May 28, 2014
+
+Bug Fixes
+---------
+* Fix check for Cluster.is_shutdown in in @run_in_executor
+  decorator
+
 2.0.0
 =====
 May 28, 2014
diff --git a/cassandra/cluster.py b/cassandra/cluster.py
@@ -130,7 +130,7 @@ def run_in_executor(f):
     @wraps(f)
     def new_f(self, *args, **kwargs):
 
-        if self._is_shutdown:
+        if self.is_shutdown:
             return
         try:
             future = self.executor.submit(f, self, *args, **kwargs)
