diff options
Diffstat (limited to 'lib/sqlalchemy/pool.py')
| -rw-r--r-- | lib/sqlalchemy/pool.py | 12 |
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"): |