diff options
author | Matus Valo <matusvalo@gmail.com> | 2021-08-30 20:04:00 +0200 |
---|---|---|
committer | Asif Saif Uddin <auvipy@gmail.com> | 2021-08-31 15:57:54 +0600 |
commit | 8a770d2f18bf3d9ff70d7fc723a24c506346cec3 (patch) | |
tree | a307f6d7a0bb590e8e600cf6c6184e45a9af6c2a /t | |
parent | 7230665e5cd82c3e1b17dc9f5e16dce085994673 (diff) | |
download | kombu-8a770d2f18bf3d9ff70d7fc723a24c506346cec3.tar.gz |
Run integration tests for kombu also with global_keyprefix
Diffstat (limited to 't')
-rw-r--r-- | t/integration/test_redis.py | 8 |
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 ) |