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

connection queue - issue non-blocking get to pool queue

Browse Source
This commit is contained in:
Roey Berman
2014-02-02 13:46:25 +02:00
parent cda56c117b
commit 1b0cbe27d5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cqlengine/connection.py
View File

@@ -142,9 +142,9 @@ class ConnectionPool(object):
a new one. a new one.
""" """
try: try:
# get with blocking=False (default) returns an item if one # get with block=False returns an item if one
# is immediately available, else raises the Empty exception # is immediately available, else raises the Empty exception
return self._queue.get() return self._queue.get(block=False)
except queue.Empty: except queue.Empty:
try: try:
return self._create_connection() return self._create_connection()