Merge "fix: mongodb tests consume storage like crazy"
This commit is contained in:
commit
583a43e371
@ -33,15 +33,12 @@ from marconi import tests as testing
|
||||
from marconi.tests.queues.storage import base
|
||||
|
||||
|
||||
class MongodbTestMixin(object):
|
||||
def _cleanup_databases(controller):
|
||||
databases = (controller.driver.message_databases +
|
||||
[controller.driver.queues_database])
|
||||
|
||||
def _purge_databases(self):
|
||||
"""Override to clean databases."""
|
||||
databases = (self.driver.message_databases +
|
||||
[self.driver.queues_database])
|
||||
|
||||
for db in databases:
|
||||
self.driver.connection.drop_database(db)
|
||||
for db in databases:
|
||||
controller.driver.connection.drop_database(db)
|
||||
|
||||
|
||||
class MongodbUtilsTest(testing.TestBase):
|
||||
@ -88,10 +85,13 @@ class MongodbUtilsTest(testing.TestBase):
|
||||
|
||||
|
||||
@testing.requires_mongodb
|
||||
class MongodbDriverTest(testing.TestBase, MongodbTestMixin):
|
||||
class MongodbDriverTest(testing.TestBase):
|
||||
|
||||
config_file = 'wsgi_mongodb.conf'
|
||||
|
||||
def _purge_databases(self):
|
||||
_cleanup_databases(self)
|
||||
|
||||
def test_db_instance(self):
|
||||
cache = oslo_cache.get_cache(self.conf)
|
||||
driver = mongodb.DataDriver(self.conf, cache)
|
||||
@ -105,12 +105,15 @@ class MongodbDriverTest(testing.TestBase, MongodbTestMixin):
|
||||
|
||||
|
||||
@testing.requires_mongodb
|
||||
class MongodbQueueTests(base.QueueControllerTest, MongodbTestMixin):
|
||||
class MongodbQueueTests(base.QueueControllerTest):
|
||||
|
||||
driver_class = mongodb.DataDriver
|
||||
config_file = 'wsgi_mongodb.conf'
|
||||
controller_class = controllers.QueueController
|
||||
|
||||
def _purge_databases(self):
|
||||
_cleanup_databases(self)
|
||||
|
||||
def _prepare_conf(self):
|
||||
self.config(options.MONGODB_GROUP,
|
||||
database=uuid.uuid4().hex)
|
||||
@ -142,7 +145,7 @@ class MongodbQueueTests(base.QueueControllerTest, MongodbTestMixin):
|
||||
|
||||
|
||||
@testing.requires_mongodb
|
||||
class MongodbMessageTests(base.MessageControllerTest, MongodbTestMixin):
|
||||
class MongodbMessageTests(base.MessageControllerTest):
|
||||
|
||||
driver_class = mongodb.DataDriver
|
||||
config_file = 'wsgi_mongodb.conf'
|
||||
@ -151,6 +154,9 @@ class MongodbMessageTests(base.MessageControllerTest, MongodbTestMixin):
|
||||
# NOTE(kgriffs): MongoDB's TTL scavenger only runs once a minute
|
||||
gc_interval = 60
|
||||
|
||||
def _purge_databases(self):
|
||||
_cleanup_databases(self)
|
||||
|
||||
def _prepare_conf(self):
|
||||
self.config(options.MONGODB_GROUP,
|
||||
database=uuid.uuid4().hex)
|
||||
@ -296,12 +302,15 @@ class MongodbMessageTests(base.MessageControllerTest, MongodbTestMixin):
|
||||
|
||||
|
||||
@testing.requires_mongodb
|
||||
class MongodbClaimTests(base.ClaimControllerTest, MongodbTestMixin):
|
||||
class MongodbClaimTests(base.ClaimControllerTest):
|
||||
|
||||
driver_class = mongodb.DataDriver
|
||||
config_file = 'wsgi_mongodb.conf'
|
||||
controller_class = controllers.ClaimController
|
||||
|
||||
def _purge_databases(self):
|
||||
_cleanup_databases(self)
|
||||
|
||||
def _prepare_conf(self):
|
||||
self.config(options.MONGODB_GROUP,
|
||||
database=uuid.uuid4().hex)
|
||||
|
Loading…
x
Reference in New Issue
Block a user