Upload storage.py

storage.py

@@ -90,12 +90,15 @@ def load_wall_posts() -> list:
         return _load_json(LOCAL_WALL_FILE, [])
 
 def save_wall_posts(posts: list) -> bool:
-    """Save wall posts to local file and sync to HF dataset."""
+    """Save wall posts to local file and async sync to HF dataset."""
     with _lock:
         ok = _save_json(LOCAL_WALL_FILE, posts[:200])  # Keep max 200
         if ok:
             # Async upload to HF dataset
-            threading.Thread(target=lambda: _upload_file(LOCAL_WALL_FILE, "wall_posts.json"), daemon=True).start()
+            threading.Thread(
+                target=lambda: _upload_file(LOCAL_WALL_FILE, "wall_posts.json"),
+                daemon=True
+            ).start()
         return ok
 
 # ===== Interactions =====
@@ -107,7 +110,10 @@ def save_interactions(data: dict) -> bool:
     with _lock:
         ok = _save_json(LOCAL_INTERACTIONS_FILE, data)
         if ok:
-            threading.Thread(target=lambda: _upload_file(LOCAL_INTERACTIONS_FILE, "interactions_v2.json"), daemon=True).start()
+            threading.Thread(
+                target=lambda: _upload_file(LOCAL_INTERACTIONS_FILE, "interactions_v2.json"),
+                daemon=True
+            ).start()
         return ok
 
 # ===== Comments =====
@@ -119,7 +125,10 @@ def save_comments(data: dict) -> bool:
     with _lock:
         ok = _save_json(LOCAL_COMMENTS_FILE, data)
         if ok:
-            threading.Thread(target=lambda: _upload_file(LOCAL_COMMENTS_FILE, "comments_v2.json"), daemon=True).start()
+            threading.Thread(
+                target=lambda: _upload_file(LOCAL_COMMENTS_FILE, "comments_v2.json"),
+                daemon=True
+            ).start()
         return ok
 
 # ===== Shorts Cache =====
@@ -131,7 +140,10 @@ def save_shorts_cache(data: dict) -> bool:
     with _lock:
         ok = _save_json(LOCAL_SHORTS_CACHE, data)
         if ok:
-            threading.Thread(target=lambda: _upload_file(LOCAL_SHORTS_CACHE, "shorts_cache.json"), daemon=True).start()
+            threading.Thread(
+                target=lambda: _upload_file(LOCAL_SHORTS_CACHE, "shorts_cache.json"),
+                daemon=True
+            ).start()
         return ok
 
 # Auto-sync on startup