sungo-ganpare commited on
Commit
159bb32
·
1 Parent(s): c21b714

チャンク処理の成功メッセージを追加し、失敗時のログを強化。APIリクエスト間に待機時間を設定。

Browse files
Files changed (1) hide show
  1. local_controller.py +9 -4
local_controller.py CHANGED
@@ -487,13 +487,18 @@ def process_audio_file(input_path_str: str, output_dir_str: str):
487
  print(f" Processing {len(chunk_paths)} chunks for {audio_filename} via API...")
488
  chunk_results = []
489
  for i, chunk_p_str in enumerate(chunk_paths):
490
- # print(f" Processing chunk {i+1}/{len(chunk_paths)} ({Path(chunk_p_str).name})...")
491
  api_result = process_chunk(chunk_p_str, audio_filename)
492
  if api_result:
493
  chunk_results.append(api_result)
494
- # else:
495
- # print(f" Failed to process chunk {Path(chunk_p_str).name}.")
496
- # time.sleep(0.5) # API負荷軽減のため短いスリープ (必要に応じて)
 
 
 
 
 
 
497
 
498
  if not chunk_results:
499
  print(f" No chunks successfully processed via API for {audio_filename}.")
 
487
  print(f" Processing {len(chunk_paths)} chunks for {audio_filename} via API...")
488
  chunk_results = []
489
  for i, chunk_p_str in enumerate(chunk_paths):
 
490
  api_result = process_chunk(chunk_p_str, audio_filename)
491
  if api_result:
492
  chunk_results.append(api_result)
493
+ print(f" Successfully processed chunk {i+1}/{len(chunk_paths)}")
494
+ else:
495
+ print(f" Failed to process chunk {i+1}/{len(chunk_paths)}")
496
+
497
+ # APIリクエスト間の待機時間を追加
498
+ if i < len(chunk_paths) - 1: # 最後のチャンクの後は待機不要
499
+ wait_seconds = 5
500
+ print(f" Waiting for {wait_seconds} seconds before processing next chunk...")
501
+ time.sleep(wait_seconds)
502
 
503
  if not chunk_results:
504
  print(f" No chunks successfully processed via API for {audio_filename}.")