From 0b7f238021169c6419e05866e1539fdf3dff0065 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@ericsson.com>
Date: Mon, 2 Sep 2024 15:59:50 +0200
Subject: [PATCH] use more queues for stress tests
---
CHANGELOG.md | 2 +-
coolamqp/__init__.py | 2 +-
stress_tests/client.py | 1 -
stress_tests/settings.py | 2 +-
4 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index f55085c..33d80fc 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -7,4 +7,4 @@ Since v1.3.2 they'll be put here and in release description.
* compile_definitions will now depend on requests
* added support for infinite (None) timeouts during start
* stress tests will run for 120 seconds now
-* stress tests will be harder
\ No newline at end of file
+* stress tests will be harder, and use more queues
\ No newline at end of file
diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py
index ad3558b..9f915c8 100644
--- a/coolamqp/__init__.py
+++ b/coolamqp/__init__.py
@@ -1 +1 @@
-__version__ = '1.3.2b2'
+__version__ = '1.3.2b3'
diff --git a/stress_tests/client.py b/stress_tests/client.py
index 74880cc..7b78d21 100644
--- a/stress_tests/client.py
+++ b/stress_tests/client.py
@@ -54,7 +54,6 @@ class Connection:
try:
self.name = self.cad_thread.free_names.popleft()
except IndexError:
- logger.warning('Ran out of free names')
raise ValueError('Cannot create a connection %s - ran out of free names',
Connection.CONNECTION_COUNTER)
self.consumer, future = cad_thread.amqp.consume(Queue(self.name))
diff --git a/stress_tests/settings.py b/stress_tests/settings.py
index 57424f4..4b3fd40 100644
--- a/stress_tests/settings.py
+++ b/stress_tests/settings.py
@@ -33,4 +33,4 @@ class LogFramesToFile:
except ValueError:
pass
-queue_names = (str(v) for v in range(100))
+queue_names = [str(v) for v in range(1000)]
--
GitLab