From b8833c7560fa988f83533d1c3590737b6360af98 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonathan=20K=C3=B6ssler?= Date: Wed, 17 Jul 2024 10:51:14 +0200 Subject: [PATCH] fix: settings mapping --- pyinfra/examples.py | 2 +- scripts/send_threaded_request.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pyinfra/examples.py b/pyinfra/examples.py index b1f7f48..6ad1fa8 100644 --- a/pyinfra/examples.py +++ b/pyinfra/examples.py @@ -28,7 +28,7 @@ def get_rabbitmq_config(settings: Dynaconf): heartbeat=settings.rabbitmq.heartbeat, input_queue_prefix=settings.rabbitmq.service_request_queue_prefix, tenant_event_queue_suffix=settings.rabbitmq.tenant_event_queue_suffix, - tenant_exchange_name=settings.rabbitmq.service_response_queue_prefix, + tenant_exchange_name=settings.rabbitmq.tenant_exchange_name, service_request_exchange_name=settings.rabbitmq.service_request_exchange_name, service_response_exchange_name=settings.rabbitmq.service_response_exchange_name, service_dead_letter_queue_name=settings.rabbitmq.service_dlq_name, diff --git a/scripts/send_threaded_request.py b/scripts/send_threaded_request.py index ca9e2b9..6824838 100644 --- a/scripts/send_threaded_request.py +++ b/scripts/send_threaded_request.py @@ -57,7 +57,7 @@ def send_tenant_event(tenant_id: str, event_type: str): def send_service_request(tenant_id: str): queue_manager = ServiceQueueManager(settings) - queue_name = f"{settings.rabbitmq.service_response_queue_prefix}_{tenant_id}" + queue_name = f"service_response_queue_{tenant_id}" queue_manager.purge_queues()