windows standard

app.py

@@ -254,21 +254,40 @@ async def upload_batch_dataset(payload: BatchUploadPayload):
             existing = DatasetDict()
             print("📂 기존 repo 없음 → 새로 생성")
 
+        def normalize_windows(record):
+            """windows 데이터를 문자열 리스트로 정규화"""
+            w = record.get("windows")
+            if isinstance(w, list):
+                if len(w) > 0 and isinstance(w[0], dict):
+                    record["windows"] = [str(v) for d in w for v in d.values()]
+                else:
+                    record["windows"] = [str(x) for x in w]
+            elif isinstance(w, dict):
+                record["windows"] = [str(v) for v in w.values()]
+            else:
+                record["windows"] = []
+            return record
+
         # 현재 사용자만 업데이트
         for user_id, records in user_data_groups.items():
             try:
-                df = pd.DataFrame(records)
-                new_dataset = Dataset.from_pandas(df)
+                # 새 데이터 정규화
+                normalized = [normalize_windows(r) for r in records]
+                new_df = pd.DataFrame(normalized)
+                new_dataset = Dataset.from_pandas(new_df)
 
                 if user_id in existing:
-                    # 기존 데이터프레임과 병합
+                    # 기존 데이터 정규화 및 병합
                     old_df = existing[user_id].to_pandas()
-                    merged = pd.concat([old_df, df], ignore_index=True)
-                    existing[user_id] = Dataset.from_pandas(merged)
-                    print(f"📊 {user_id}: 기존 데이터와 병합 ({len(old_df)} + {len(df)} = {len(merged)}개 레코드)")
+                    old_df["windows"] = old_df["windows"].apply(
+                        lambda w: [str(v) for v in w] if isinstance(w, list) else []
+                    )
+                    merged_df = pd.concat([old_df, new_df], ignore_index=True)
+                    existing[user_id] = Dataset.from_pandas(merged_df)
+                    print(f"📊 {user_id}: 기존 데이터와 병합 ({len(old_df)} + {len(new_df)} = {len(merged_df)}개 레코드)")
                 else:
                     existing[user_id] = new_dataset
-                    print(f"📊 {user_id}: 신규 데이터 추가 ({len(df)}개 레코드)")
+                    print(f"📊 {user_id}: 신규 데이터 추가 ({len(new_df)}개 레코드)")
 
                 results[user_id] = {
                     "status": "success",