Feat/queue connector

backend/workflow_manager/endpoint/destination.py

@@ -526,7 +526,7 @@ def _push_to_queue(
                 file_content=file_content_base64,
             )
             # Convert the result dictionary to a JSON string
-            queue_result_json = json.dumps(queue_result)
+            queue_result_json = json.dumps(queue_result.to_serializable_dict())
             conn = QueueUtils.get_queue_inst()
             # Enqueue the JSON string
             conn.enqueue(queue_name=q_name, message=queue_result_json)

backend/workflow_manager/endpoint/queue_utils.py

@@ -39,3 +39,13 @@ class QueueResult:
     result: Any
     workflow_id: str
     file_content: str
+
+    def to_serializable_dict(self):
+        return {
+            "file": self.file,
+            "whisper_hash": self.whisper_hash,
+            "status": self.status,
+            "result": self.result,
+            "workflow_id": self.workflow_id,
+            "file_content": self.file_content,
+        }

frontend/src/routes/Router.jsx

@@ -53,8 +53,6 @@ try {
     require("../plugins/app-deployment/AppDeployments.jsx").AppDeployments;
   ChatAppPage =
     require("../plugins/app-deployment/chat-app/ChatAppPage.jsx").ChatAppPage;
-  ChatAppLayout =
-    require("../plugins/app-deployment/chat-app/ChatAppLayout.jsx").ChatAppLayout;
 } catch (err) {
   // Do nothing, Not-found Page will be triggered.
 }