diff --git a/pycassa/pool.py b/pycassa/pool.py index 614d309d..f6b21c52 100644 --- a/pycassa/pool.py +++ b/pycassa/pool.py @@ -585,10 +585,10 @@ def dispose(self): conn = self._q.get(False) conn._dispose_wrapper( reason="Pool %s is being disposed" % id(self)) + self._decrement_overflow() except Queue.Empty: break - self._overflow = 0 - self.size() self._notify_on_pool_dispose() def size(self):