Update handler.py

handler.py

@@ -8,18 +8,17 @@ class EndpointHandler:
         """
         self.topic_model = BERTopic.load(model_path)
 
-    def preprocess(self, data):
-        """
-        Preprocess the incoming request data.
-        - Extract text input from the request.
-        """
-        try:
-            # Parse the incoming data
-            body = json.loads(data)
-            text_input = body.get("text", "")
-            return text_input
-        except Exception as e:
-            raise ValueError(f"Error during preprocessing: {str(e)}")
+def preprocess(self, data):
+    """
+    Preprocess the incoming request data.
+    - Extract text input from the request.
+    """
+    try:
+        # Directly work with the incoming data dictionary
+        text_input = data.get("text", "")
+        return text_input
+    except Exception as e:
+        raise ValueError(f"Error during preprocessing: {str(e)}")
 
     def inference(self, text_input):
         """