- adjust _revalidate_connection() again such that we pass a _wrap=False

to it, so that we say we will do the wrapping just once right here
in _execute_context() / _execute_default().  An adjustment is made
to _handle_dbapi_error() to not assume self.__connection in case
we are already in an invalidated state

further adjustment to
0639c199a547343d62134d2f233225fd2862ec45, 41e7253dee168b8c26c49, #3266

1 files changed, 4 insertions, 1 deletions

diff --git a/lib/sqlalchemy/engine/threadlocal.py b/lib/sqlalchemy/engine/threadlocal.py
index 71caac626..824b68fdf 100644
--- a/lib/sqlalchemy/engine/threadlocal.py
+++ b/lib/sqlalchemy/engine/threadlocal.py
@@ -59,7 +59,10 @@ class TLEngine(base.Engine):
             # guards against pool-level reapers, if desired.
             # or not connection.connection.is_valid:
             connection = self._tl_connection_cls(
-                self, self._wrap_pool_connect(self.pool.connect), **kw)
+                self,
+                self._wrap_pool_connect(
+                    self.pool.connect, connection, wrap=True),
+                **kw)
             self._connections.conn = weakref.ref(connection)
 
         return connection._increment_connect()