factorstudios commited on
Commit
9144bbc
·
verified ·
1 Parent(s): 4aba119

Update server.py

Browse files
Files changed (1) hide show
  1. server.py +13 -1
server.py CHANGED
@@ -189,9 +189,19 @@ async def load_progress_file() -> Dict:
189
 
190
  with open(progress_path, 'r') as f:
191
  progress = json.load(f)
 
 
 
 
 
 
 
 
 
192
  compressed_count = len(progress.get('compressed', []))
193
  failed_count = len(progress.get('failed', []))
194
- print(f"✓ Loaded progress: {compressed_count} compressed, {failed_count} failed")
 
195
  return progress
196
  except Exception as e:
197
  print(f"⊘ No existing progress file or load failed: {str(e)[:100]}")
@@ -492,6 +502,8 @@ async def scan_and_compress_videos():
492
  # Check if meets compression threshold
493
  if file_size_mb < SIZE_THRESHOLD_MB:
494
  print(f"⊘ Below threshold ({file_size_mb:.1f}MB < {SIZE_THRESHOLD_MB}MB), skipping")
 
 
495
  progress["compressed"].append({
496
  "path": video_info["path"],
497
  "file_name": video_info["file_name"],
 
189
 
190
  with open(progress_path, 'r') as f:
191
  progress = json.load(f)
192
+
193
+ # Ensure all required keys exist (for backwards compatibility with old progress files)
194
+ if "processing" not in progress:
195
+ progress["processing"] = []
196
+ if "compressed" not in progress:
197
+ progress["compressed"] = []
198
+ if "failed" not in progress:
199
+ progress["failed"] = []
200
+
201
  compressed_count = len(progress.get('compressed', []))
202
  failed_count = len(progress.get('failed', []))
203
+ processing_count = len(progress.get('processing', []))
204
+ print(f"✓ Loaded progress: {compressed_count} compressed, {failed_count} failed, {processing_count} processing")
205
  return progress
206
  except Exception as e:
207
  print(f"⊘ No existing progress file or load failed: {str(e)[:100]}")
 
502
  # Check if meets compression threshold
503
  if file_size_mb < SIZE_THRESHOLD_MB:
504
  print(f"⊘ Below threshold ({file_size_mb:.1f}MB < {SIZE_THRESHOLD_MB}MB), skipping")
505
+ # Remove from processing and add to compressed (skipped)
506
+ progress["processing"] = [f for f in progress["processing"] if f["path"] != video_info["path"]]
507
  progress["compressed"].append({
508
  "path": video_info["path"],
509
  "file_name": video_info["file_name"],