]> git.ipfire.org Git - thirdparty/sqlalchemy/sqlalchemy.git/commitdiff
uurg, add a use_reaper argument and have zoomark skip the reaping for its very specia...
authorMike Bayer <mike_mp@zzzcomputing.com>
Tue, 26 Apr 2011 02:29:59 +0000 (22:29 -0400)
committerMike Bayer <mike_mp@zzzcomputing.com>
Tue, 26 Apr 2011 02:29:59 +0000 (22:29 -0400)
test/aaa_profiling/test_zoomark.py
test/aaa_profiling/test_zoomark_orm.py
test/lib/engines.py

index 304453a640db186b2f82a53c45754c98d9e88e85..587d522cdaf78b2ddb3f8a5ad46c5cb007efb1ac 100644 (file)
@@ -33,7 +33,7 @@ class ZooMarkTest(fixtures.TestBase):
         global metadata
         creator = testing.db.pool._creator
         recorder = lambda : dbapi_session.recorder(creator())
-        engine = engines.testing_engine(options={'creator': recorder})
+        engine = engines.testing_engine(options={'creator': recorder, 'use_reaper':False})
         metadata = MetaData(engine)
         engine.connect()
 
index 507121abde44c0fbd45d551f6c946982b1e0ec86..18c1f037f7e643988367dfccb352a1c108c644df 100644 (file)
@@ -35,7 +35,7 @@ class ZooMarkTest(fixtures.TestBase):
         global metadata, session
         creator = testing.db.pool._creator
         recorder = lambda : dbapi_session.recorder(creator())
-        engine = engines.testing_engine(options={'creator': recorder})
+        engine = engines.testing_engine(options={'creator': recorder, 'use_reaper':False})
         metadata = MetaData(engine)
         session = sessionmaker()()
         engine.connect()
index 3a5132b8b6f9c26c9772166778f1756140ec27e8..0c980c376fb2b21c12f5a5fa2bac94611c784c79 100644 (file)
@@ -148,6 +148,11 @@ def testing_engine(url=None, options=None):
     from sqlalchemy import create_engine
     from test.lib.assertsql import asserter
 
+    if not options:
+        use_reaper = True
+    else:
+        use_reaper = options.pop('use_reaper', True)
+
     url = url or config.db_url
     options = options or config.db_opts
 
@@ -157,12 +162,9 @@ def testing_engine(url=None, options=None):
         engine.pool._max_overflow = 0
     event.listen(engine, 'after_execute', asserter.execute)
     event.listen(engine, 'after_cursor_execute', asserter.cursor_execute)
-    event.listen(engine.pool, 'checkout', testing_reaper.checkout)
-
-    # may want to call this, results
-    # in first-connect initializers
-    #engine.connect()
-    testing_reaper.add_engine(engine)
+    if use_reaper:
+        event.listen(engine.pool, 'checkout', testing_reaper.checkout)
+        testing_reaper.add_engine(engine)
 
     return engine