From 9b20a67ace7f7b9dbc85aadc6a4b3d6bba759b4e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonathan=20K=C3=B6ssler?= Date: Thu, 11 Jul 2024 11:41:09 +0200 Subject: [PATCH] feat: wip for multiple tenants - for pkg build --- pyinfra/queue/threaded_tenants.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pyinfra/queue/threaded_tenants.py b/pyinfra/queue/threaded_tenants.py index 9a00de4..a18e66f 100644 --- a/pyinfra/queue/threaded_tenants.py +++ b/pyinfra/queue/threaded_tenants.py @@ -257,8 +257,8 @@ class ServiceQueueManager(BaseQueueManager): self.tenant_ids = self.get_initial_tenant_ids(tenant_endpoint_url=settings.storage.tenant_server.endpoint) def initialize_queues(self) -> None: - self.channel.exchange_declare(exchange=self.service_request_exchange_name, exchange_type="direct") - self.channel.exchange_declare(exchange=self.service_response_exchange_name, exchange_type="direct") + self.channel.exchange_declare(exchange=self.service_request_exchange_name, exchange_type="direct", durable=True) + self.channel.exchange_declare(exchange=self.service_response_exchange_name, exchange_type="direct", durable=True) for tenant_id in self.tenant_ids: request_queue_name = f"{self.service_request_queue_prefix}_{tenant_id}"