chore: format code and update changelog for parallel publishing

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: baogorek

changelog_entry.yaml

@@ -14,3 +14,6 @@
     added:
     - Added CPS_2024_Full class for full-sample 2024 CPS generation
     - Added raw_cache utility for Census data caching
+    - Added atomic parallel local area H5 publishing with Modal Volume staging
+    - Added manifest validation with SHA256 checksums for versioned uploads
+    - Added HuggingFace retry logic with exponential backoff to fix timeout errors

modal_app/local_area.py

@@ -361,8 +361,12 @@ def coordinate_publish(
     calibration_dir.mkdir(parents=True, exist_ok=True)
 
     # hf_hub_download preserves directory structure, so files are in calibration/ subdir
-    weights_path = calibration_dir / "calibration" / "w_district_calibration.npy"
-    dataset_path = calibration_dir / "calibration" / "stratified_extended_cps.h5"
+    weights_path = (
+        calibration_dir / "calibration" / "w_district_calibration.npy"
+    )
+    dataset_path = (
+        calibration_dir / "calibration" / "stratified_extended_cps.h5"
+    )
     db_path = calibration_dir / "calibration" / "policy_data.db"
 
     if not all(p.exists() for p in [weights_path, dataset_path, db_path]):

modal_app/worker_script.py

@@ -95,11 +95,13 @@ def main():
 
         except Exception as e:
             results["failed"].append(f"{item_type}:{item_id}")
-            results["errors"].append({
-                "item": f"{item_type}:{item_id}",
-                "error": str(e),
-                "traceback": traceback.format_exc(),
-            })
+            results["errors"].append(
+                {
+                    "item": f"{item_type}:{item_id}",
+                    "error": str(e),
+                    "traceback": traceback.format_exc(),
+                }
+            )
             print(f"FAILED {item_type}:{item_id}: {e}", file=sys.stderr)
 
     print(json.dumps(results))