From 5e7cc3812074d91e8d7d85058554bb1175bf8070 Mon Sep 17 00:00:00 2001 From: Akshay Dahiya Date: Thu, 27 Jul 2023 14:54:07 +0530 Subject: [PATCH] fix: payload commit queue finalized routing key --- snapshotter/processor_distributor.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/snapshotter/processor_distributor.py b/snapshotter/processor_distributor.py index 86b724e8..d9e4182e 100644 --- a/snapshotter/processor_distributor.py +++ b/snapshotter/processor_distributor.py @@ -70,8 +70,7 @@ def __init__(self, name, **kwargs): self._payload_commit_exchange_name = ( f'{settings.rabbitmq.setup.commit_payload.exchange}:{settings.namespace}' ) - self._payload_commit_routing_key = f'powerloom-backend-commit-payload:{settings.namespace}' - f':{settings.instance_id}.Finalized' + self._payload_commit_routing_key = f'powerloom-backend-commit-payload:{settings.namespace}:{settings.instance_id}.Finalized' self.projects_config = copy.copy(projects_config) self._upcoming_project_changes = defaultdict(list)