- moved out to on_before_execute, on_after_execute. not much option here,

need both forms, the wrapping thing is just silly
- fixed the listen() to not re-wrap continuously.

1 files changed, 2 insertions, 2 deletions

diff --git a/lib/sqlalchemy/engine/threadlocal.py b/lib/sqlalchemy/engine/threadlocal.py
index b6e687b7c..c982afd63 100644
--- a/lib/sqlalchemy/engine/threadlocal.py
+++ b/lib/sqlalchemy/engine/threadlocal.py
@@ -30,8 +30,8 @@ class TLConnection(base.Connection):
 class TLEvents(base.EngineEvents):
     @classmethod
     def listen(cls, fn, identifier, target):
-        if issubclass(target.TLConnection, TLConnection):
-            target.TLConnection = base._proxy_connection_cls(
+        if target.TLConnection is TLConnection:
+            target.TLConnection = base._listener_connection_cls(
                                         TLConnection, 
                                         target.dispatch)
         base.EngineEvents.listen(fn, identifier, target)