Made 'prompt_data_update' pub/sub

NeonGeckoCom · Jan 17, 2025 · f16d922 · f16d922
1 parent 47b7005
commit f16d922
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/services/klatchat_observer/controller.py b/services/klatchat_observer/controller.py
@@ -980,8 +980,8 @@ def forward_prompts_data_update(self, data: dict):
         self.send_message(
             request_data=data,
             vhost=self.get_vhost("chatbots"),
-            queue="prompts_data_update",
-            expiration=3000,
+            exchange="prompts_data_update",
+            exchange_type=ExchangeType.fanout.value,
         )
 
     def _sio_emit(self, event: str, data: dict):