fix: payload commit queue finalized routing key

PowerLoom · Jul 27, 2023 · 5e7cc38 · 5e7cc38
1 parent 00aa45b
commit 5e7cc38
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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)