fix:转发清洗模式时使用原始数据

2026-06-02 05:54:40 +00:00 · 2026-05-23 16:10:10 +08:00
parent b347c6af57
commit 001e94f03f
1 changed files with 3 additions and 1 deletions
@@ -122,7 +122,9 @@ async def dispatch_to_staging(
        try:
            data_list = []
            for item in data:
-                if hasattr(item, "model_dump"):
+                if hasattr(item, "_raw_input_data") and item._raw_input_data:
+                    data_list.append(item._raw_input_data)
+                elif hasattr(item, "model_dump"):
                    data_list.append(item.model_dump())
                elif isinstance(item, dict):
                    data_list.append(item)