root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Merge pull request #13511 from rabbitmq/fix-test-flakes-in-python_SUITE 

Fix test flakes in `python_SUITE`
This commit is contained in:
Jean-Sébastien Pédron 2025-03-13 12:52:31 +01:00 committed by GitHub
parent 38e7bd7f43 337292758c
commit 8486728f85
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py vendored
View File

@ -182,7 +182,7 @@ class TestParsing(unittest.TestCase):
def test_broadcast(self): def test_broadcast(self):
''' Single message should be delivered to two consumers: ''' Single message should be delivered to two consumers:
amq.topic --routing_key--> first_queue --> first_connection amq.topic --routing_key--> first_queue --> first_connection
\--routing_key--> second_queue--> second_connection \\--routing_key--> second_queue--> second_connection
''' '''
subscribe=( 'SUBSCRIBE\n' subscribe=( 'SUBSCRIBE\n'
'id: XsKNhAf\n' 'id: XsKNhAf\n'
@ -336,4 +336,4 @@ if __name__ == '__main__':
modules = [ modules = [
__name__ __name__
] ]
test_runner.run_unittests(modules) test_runner.run_unittests(modules)

6
deps/rabbitmq_stomp/test/python_SUITE_data/src/x_queue_name.py vendored
View File

@ -36,7 +36,7 @@ class TestUserGeneratedQueueName(base.BaseTest):
body='Hello World!') body='Hello World!')
# check if we receive the message from the STOMP subscription # check if we receive the message from the STOMP subscription
self.assertTrue(self.listener.wait(2), "initial message not received") self.assertTrue(self.listener.wait(5), "initial message not received")
self.assertEqual(1, len(self.listener.messages)) self.assertEqual(1, len(self.listener.messages))
self.conn.disconnect() self.conn.disconnect()
@ -64,7 +64,7 @@ class TestUserGeneratedQueueName(base.BaseTest):
body='Hello World!') body='Hello World!')
# check if we receive the message from the STOMP subscription # check if we receive the message from the STOMP subscription
self.assertTrue(self.listener.wait(2), "initial message not received") self.assertTrue(self.listener.wait(5), "initial message not received")
self.assertEqual(1, len(self.listener.messages)) self.assertEqual(1, len(self.listener.messages))
self.conn.disconnect() self.conn.disconnect()
@ -76,4 +76,4 @@ if __name__ == '__main__':
modules = [ modules = [
__name__ __name__
] ]
test_runner.run_unittests(modules) test_runner.run_unittests(modules)