]> git.ipfire.org Git - thirdparty/sqlalchemy/sqlalchemy.git/commitdiff
ding
authorMike Bayer <mike_mp@zzzcomputing.com>
Sun, 7 Nov 2010 17:54:54 +0000 (12:54 -0500)
committerMike Bayer <mike_mp@zzzcomputing.com>
Sun, 7 Nov 2010 17:54:54 +0000 (12:54 -0500)
lib/sqlalchemy/pool.py
test/engine/test_pool.py

index 7d916620511f4d58849fee2ea35e1dd7924012eb..4c8797fd5168f576fe6e5cadb09015b319e3e4f8 100644 (file)
@@ -126,7 +126,7 @@ class Pool(log.Identified):
         self._reset_on_return = reset_on_return
         self.echo = echo
         if _dispatch:
-            self.dispatch.update(_dispatch)
+            self.dispatch.update(_dispatch, only_propagate=False)
         if listeners:
             util.warn_deprecated(
                         "The 'listeners' argument to Pool (and "
index 29591f11e5d21f5665dcdb93212766647afff41e..8d0039cb897d9152411a887247ebdb08875d6a01 100644 (file)
@@ -392,9 +392,9 @@ class PoolTest(PoolTestBase):
 
             def assert_listeners(p, total, conn, cout, cin):
                 for instance in (p, p.recreate()):
-                    self.assert_(len(instance.dispatch.on_connect) == conn)
-                    self.assert_(len(instance.dispatch.on_checkout) == cout)
-                    self.assert_(len(instance.dispatch.on_checkin) == cin)
+                    eq_(len(instance.dispatch.on_connect), conn)
+                    eq_(len(instance.dispatch.on_checkout), cout)
+                    eq_(len(instance.dispatch.on_checkin), cin)
 
             p = _pool()
             assert_listeners(p, 0, 0, 0, 0)