Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

fix: settings mapping

Browse Source
This commit is contained in:
Jonathan Kössler 2024-07-17 10:51:14 +02:00
parent 02665a5ef8
commit b8833c7560
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pyinfra/examples.py
View File

@ -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,

2
scripts/send_threaded_request.py
View File

@ -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()