Revert "[DataProcessor] Refactor and unify text/multimodal processor pipeline…" (#7851)

This reverts commit 5820553.

Author: EmmonsCurse

fastdeploy/entrypoints/chat_utils.py

@@ -199,10 +199,11 @@ def parse_chat_messages(messages: List[ChatCompletionMessageParam]):
         role = message["role"]
         content = message["content"]
 
+        parsed_content = []
         if content is None:
-            parsed_content = content
+            parsed_content = []
         elif isinstance(content, str):
-            parsed_content = content
+            parsed_content = [{"type": "text", "text": content}]
         else:
             parsed_content = [parse_content_part(mm_parser, part) for part in content]
 

fastdeploy/entrypoints/llm.py

@@ -276,7 +276,7 @@ def chat(
                 raise RuntimeError(f"Failed to validate 'tools' parameter in chat method: {e}") from e
 
         req_ids = self._add_request(
-            prompts=messages,
+            prompts=[{"messages": msg} for msg in messages],
             sampling_params=sampling_params,
             chat_template_kwargs=chat_template_kwargs,
             chat_template=chat_template,
@@ -326,21 +326,11 @@ def _add_request(
                     "prompt": prompts[i],
                     "request_id": request_id,
                 }
-            elif isinstance(prompts[i], list) and len(prompts[i]) == 0:
-                raise ValueError(
-                    f"prompts[{i}] is an empty list. Expected a non-empty list of int (prompt_token_ids) "
-                    "or a non-empty list of dict (messages)."
-                )
             elif isinstance(prompts[i], list) and isinstance(prompts[i][0], int):
                 tasks = {
                     "prompt_token_ids": prompts[i],
                     "request_id": request_id,
                 }
-            elif isinstance(prompts[i], list) and isinstance(prompts[i][0], dict):
-                tasks = {
-                    "messages": prompts[i],
-                    "request_id": request_id,
-                }
             elif isinstance(prompts[i], dict):
                 tasks = prompts[i]
                 tasks["request_id"] = request_id