openstack/zaqar
Code Issues Proposed changes

fix the gateway CI error

Browse Source 
Change-Id: I346e829b8c68f2f5444e098c36c7f0c7a32f6fb9
This commit is contained in:
hwang 2023-07-20 18:12:15 -07:00
parent d27fb63796
commit ef62a26dc4
3 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
devstack/plugin.sh
View File

@ -197,6 +197,7 @@ function configure_mongodb {
install_package libssl1.1
install_package mongodb-org
restart_service mongod
sudo systemctl status mongod
else
install_package mongodb-server
restart_service mongodb

1
tools/test-setup.sh
View File

@ -42,6 +42,7 @@ if [[ $ubuntu_version == '22.04' ]]; then
sudo apt install -y libssl1.1
sudo apt install -y mongodb-org
sudo systemctl restart mongod
sudo systemctl status mongod
else
sudo apt-get install -y mongodb
sudo systemctl restart mongodb

14
zaqar/tests/unit/storage/base.py
View File

@ -1101,9 +1101,9 @@ class ClaimControllerTest(ControllerBaseTest):
self.assertEqual({"key": "value"}, expected_msg["body"])
def test_delay_queue(self):
meta = {'ttl': 1, 'grace': 0}
meta = {'ttl': 2, 'grace': 0}
# Set default message delay for queue.
metadata = {'_default_message_delay': 2}
metadata = {'_default_message_delay': 3}
self.queue_controller.set_metadata(self.queue_name,
metadata,
project=self.project)
@ -1128,12 +1128,12 @@ class ClaimControllerTest(ControllerBaseTest):
project=self.project)
self.assertIsNone(claim_id)
self.assertEqual(0, len(list(messages)))
time.sleep(3)
time.sleep(4)
claim_id, messages = self.controller.create(self.queue_name, meta,
project=self.project)
self.assertIsNotNone(claim_id)
self.assertEqual(1, len(list(messages)))
time.sleep(1)
time.sleep(2)
self.message_controller.delete(self.queue_name, ids[0],
project=self.project)
@ -1154,12 +1154,12 @@ class ClaimControllerTest(ControllerBaseTest):
project=self.project)
self.assertIsNone(claim_id)
self.assertEqual(0, len(list(messages)))
time.sleep(1)
time.sleep(2)
claim_id, messages = self.controller.create(self.queue_name, meta,
project=self.project)
self.assertIsNotNone(claim_id)
self.assertEqual(1, len(list(messages)))
time.sleep(1)
time.sleep(2)
self.message_controller.delete(self.queue_name, ids[0],
project=self.project)
@ -1180,7 +1180,7 @@ class ClaimControllerTest(ControllerBaseTest):
project=self.project)
self.assertIsNotNone(claim_id)
self.assertEqual(1, len(list(messages)))
time.sleep(1)
time.sleep(2)
self.message_controller.delete(self.queue_name, ids[0],
project=self.project)