summaryrefslogtreecommitdiff
path: root/t
diff options
context:
space:
mode:
authorMatus Valo <matusvalo@gmail.com>2021-08-30 20:04:00 +0200
committerAsif Saif Uddin <auvipy@gmail.com>2021-08-31 15:57:54 +0600
commit8a770d2f18bf3d9ff70d7fc723a24c506346cec3 (patch)
treea307f6d7a0bb590e8e600cf6c6184e45a9af6c2a /t
parent7230665e5cd82c3e1b17dc9f5e16dce085994673 (diff)
downloadkombu-8a770d2f18bf3d9ff70d7fc723a24c506346cec3.tar.gz
Run integration tests for kombu also with global_keyprefix
Diffstat (limited to 't')
-rw-r--r--t/integration/test_redis.py8
1 files changed, 5 insertions, 3 deletions
diff --git a/t/integration/test_redis.py b/t/integration/test_redis.py
index 82eeceb2..0d38efb6 100644
--- a/t/integration/test_redis.py
+++ b/t/integration/test_redis.py
@@ -9,11 +9,12 @@ from .common import BaseExchangeTypes, BasePriority, BasicFunctionality
def get_connection(
- hostname, port, vhost):
- return kombu.Connection(f'redis://{hostname}:{port}')
+ hostname, port, vhost, transport_options=None):
+ return kombu.Connection(
+ f'redis://{hostname}:{port}', transport_options=transport_options)
-@pytest.fixture()
+@pytest.fixture(params=[None, {'global_keyprefix': '_prefixed_'}])
def connection(request):
# this fixture yields plain connections to broker and TLS encrypted
return get_connection(
@@ -22,6 +23,7 @@ def connection(request):
vhost=getattr(
request.config, "slaveinput", {}
).get("slaveid", None),
+ transport_options=request.param
)