summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/pool.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2008-08-13 22:49:38 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2008-08-13 22:49:38 +0000
commit10aeb7346d58e5fb1fc762aa7a44574fd745b9c1 (patch)
tree94e9bd41d73b957ab8cc0ddbf1e8c5bd1c6e78d8 /lib/sqlalchemy/pool.py
parentcd7678a965594ff2db153a7cade0fe8555bd0d38 (diff)
downloadsqlalchemy-10aeb7346d58e5fb1fc762aa7a44574fd745b9c1.tar.gz
dont rely upon AttributeError to test for None
Diffstat (limited to 'lib/sqlalchemy/pool.py')
-rw-r--r--lib/sqlalchemy/pool.py12
1 files changed, 8 insertions, 4 deletions
diff --git a/lib/sqlalchemy/pool.py b/lib/sqlalchemy/pool.py
index ddf7cb51e..c0d98ffc4 100644
--- a/lib/sqlalchemy/pool.py
+++ b/lib/sqlalchemy/pool.py
@@ -161,11 +161,15 @@ class Pool(object):
return _ConnectionFairy(self).checkout()
try:
- return self._threadconns.current().checkout()
+ rec = self._threadconns.current()
+ if rec:
+ return rec.checkout()
except AttributeError:
- agent = _ConnectionFairy(self)
- self._threadconns.current = weakref.ref(agent)
- return agent.checkout()
+ pass
+
+ agent = _ConnectionFairy(self)
+ self._threadconns.current = weakref.ref(agent)
+ return agent.checkout()
def return_conn(self, record):
if self._use_threadlocal and hasattr(self._threadconns, "current"):