try another fix

2024-11-10 01:25:21 +00:00 · 2023-10-10 07:42:30 +00:00 · 2023-10-10 07:42:30 +00:00 · 47512f7b40
commit 47512f7b40
parent 686c3b458d
1 changed files with 1 additions and 1 deletions
--- a/tests/integration/test_storage_rabbitmq/test.py
+++ b/tests/integration/test_storage_rabbitmq/test.py
@ -2744,7 +2744,7 @@ def test_rabbitmq_random_detach(rabbitmq_cluster):
                exchange="test_sharding",
                routing_key="",
                properties=pika.BasicProperties(message_id=mes_id),
-                body=message,
+                body=messages[-1],
            )
        connection.close()