Merge "Speed up message expiration tests"
This commit is contained in:
commit
27ca6e9118
@ -583,15 +583,20 @@ class MessageControllerTest(ControllerBaseTest):
|
|||||||
client_uuid=client_uuid)
|
client_uuid=client_uuid)
|
||||||
|
|
||||||
# NOTE(kgriffs): Allow for automatic GC of claims, messages
|
# NOTE(kgriffs): Allow for automatic GC of claims, messages
|
||||||
time.sleep(self.gc_interval)
|
for i in range(self.gc_interval):
|
||||||
|
time.sleep(1)
|
||||||
|
|
||||||
# NOTE(kgriffs): Some drivers require a manual GC to be
|
# NOTE(kgriffs): Some drivers require a manual GC to be
|
||||||
# triggered to clean up claims and messages.
|
# triggered to clean up claims and messages.
|
||||||
self.driver.gc()
|
self.driver.gc()
|
||||||
|
|
||||||
with testing.expect(errors.DoesNotExist):
|
try:
|
||||||
self.controller.get(self.queue_name, msgid_expired,
|
self.controller.get(self.queue_name, msgid_expired,
|
||||||
project=self.project)
|
project=self.project)
|
||||||
|
except errors.DoesNotExist:
|
||||||
|
break
|
||||||
|
else:
|
||||||
|
self.fail("Didn't remove the queue")
|
||||||
|
|
||||||
stats = self.queue_controller.stats(self.queue_name,
|
stats = self.queue_controller.stats(self.queue_name,
|
||||||
project=self.project)
|
project=self.project)
|
||||||
|
Loading…
Reference in New Issue
Block a user