diff --git a/backend/workflow_manager/endpoint/destination.py b/backend/workflow_manager/endpoint/destination.py index 6b88dd86c..58fc265bc 100644 --- a/backend/workflow_manager/endpoint/destination.py +++ b/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) diff --git a/backend/workflow_manager/endpoint/queue_utils.py b/backend/workflow_manager/endpoint/queue_utils.py index bbb4dddb3..8bc157827 100644 --- a/backend/workflow_manager/endpoint/queue_utils.py +++ b/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, + } diff --git a/frontend/src/routes/Router.jsx b/frontend/src/routes/Router.jsx index d564714c0..47bc7c8ba 100644 --- a/frontend/src/routes/Router.jsx +++ b/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. }