Update processing.py

processing.py

@@ -85,8 +85,19 @@ def refresh_auto_output():
     except Exception as e:
         return None, f"Error refreshing output: {str(e)}"
 
+import logging
+
+# Loglama ayarları
+logging.basicConfig(
+    level=logging.DEBUG,
+    filename='utils.log',
+    filemode='a',
+    format='%(asctime)s - %(levelname)s - %(message)s'
+)
+
 def update_progress_html(progress_label, progress_percent):
-    progress_percent = min(max(round(progress_percent), 0), 100)  # %1 hassasiyet ve sınır kontrolü
+    """Gradio arayüzü için ilerleme çubuğu HTML'si oluşturur."""
+    progress_percent = min(max(round(progress_percent), 0), 100)  # %1 hassasiyet
     return f"""
     <div id="custom-progress" style="margin-top: 10px;">
         <div style="font-size: 1rem; color: #C0C0C0; margin-bottom: 5px;" id="progress-label">{progress_label}</div>
@@ -104,6 +115,103 @@ def extract_model_name_from_checkpoint(checkpoint_path):
     print(f"Original checkpoint path: {checkpoint_path}, extracted model_name: {model_name}")
     return model_name.strip()
 
+Hata mesajlarını inceledim ve sorun, run_command_and_process_files fonksiyonunda logging modülünün tanımlı olmaması nedeniyle ortaya çıkıyor. Bu, NameError: name 'logging' is not defined hatasına neden oluyor. Ayrıca, önceki konuşmalarımızda tqdm'yi kaldırarak time modülüyle %1'lik artışlarla (örneğin %23, %24, %25) ilerleme takibi yapmayı hedeflediğimiz için, bu entegrasyonu da tutarlı bir şekilde uygulayacağız. Aşağıda, hatayı çözmek ve istenen ilerleme takibini sağlamak için adım adım çözüm sunuyorum.
+
+Hata Analizi
+Hata Detayları:
+Birincil Hata: logging.info çağrısı, logging modülünün run_command_and_process_files fonksiyonunda tanımlı olmaması nedeniyle NameError üretiyor (satır 128, processing.py).
+İkincil Hata: Hata işleme bloğunda (except bloğu, satır 315), yine logging.error çağrısı aynı NameError'ü tetikliyor.
+Dosya ve Konum: Hata, /home/user/app/processing.py içinde run_command_and_process_files fonksiyonunda meydana geliyor.
+Bağlam: process_audio fonksiyonu, run_command_and_process_files üzerinden bir ses dosyasını işlerken bu hatayla karşılaşıyor.
+Olası Nedenler:
+logging modülü, processing.py dosyasında içe aktarılmamış.
+Önceki kod düzenlemelerinde logging import'u atlanmış veya yanlışlıkla silinmiş.
+run_command_and_process_files fonksiyonu, bağımsız bir modül olarak çalıştırıldığında bağımlılıkları eksik olabilir.
+Hedefler:
+NameError hatasını çözmek için logging modülünü processing.py dosyasına ekleyeceğiz.
+run_command_and_process_files fonksiyonunu, tqdm'yi tamamen kaldırarak ve time modülüyle %1'lik ilerleme güncellemeleriyle Gradio arayüzüne uyumlu hale getireceğiz.
+process_audio ve ilgili fonksiyonların hata yönetimini güçlendireceğiz.
+ZeroGPU (Hugging Face Spaces) ortamında uyumluluğu koruyacağız.
+Çözüm
+1. logging Modülünü Ekleme
+NameError'ü çözmek için processing.py dosyasına logging modülünü içe aktaracağız ve loglama ayarlarını yapılandıracağız. Ayrıca, log dosyasının (utils.log) doğru çalıştığından emin olacağız.
+
+python
+
+Collapse
+
+Wrap
+
+Run
+
+Copy
+import logging
+
+# Loglama ayarları
+logging.basicConfig(
+    level=logging.DEBUG,
+    filename='utils.log',
+    filemode='a',
+    format='%(asctime)s - %(levelname)s - %(message)s'
+)
+Bu kodu processing.py dosyasının en üstüne ekleyeceğiz.
+
+2. run_command_and_process_files Fonksiyonunu Güncelleme
+run_command_and_process_files fonksiyonunu, logging hatasını düzelterek, tqdm'yi kaldırarak ve time modülüyle %1'lik ilerleme takibi ekleyerek güncelliyoruz. Ayrıca, hata yönetimini güçlendirelim ve Gradio arayüzüyle uyumluluğu sağlayalım.
+
+Aşağıda, güncellenmiş run_command_and_process_files fonksiyonu:
+
+python
+
+Collapse
+
+Wrap
+
+Run
+
+Copy
+import subprocess
+import shutil
+import time
+import glob
+import os
+import librosa
+import soundfile as sf
+import sys
+import traceback
+import logging
+
+# Loglama ayarları
+logging.basicConfig(
+    level=logging.DEBUG,
+    filename='utils.log',
+    filemode='a',
+    format='%(asctime)s - %(levelname)s - %(message)s'
+)
+
+from assets.i18n.i18n import I18nAuto
+i18n = I18nAuto()
+
+def extract_model_name_from_checkpoint(checkpoint_path):
+    """Checkpoint dosya adından model adını çıkarır."""
+    return os.path.splitext(os.path.basename(checkpoint_path))[0]
+
+def sanitize_filename(filename):
+    """Dosya adını güvenli hale getirir."""
+    return "".join(c if c.isalnum() or c in "._-" else "-" for c in filename)
+
+def update_progress_html(progress_label, progress_percent):
+    """Gradio arayüzü için ilerleme çubuğu HTML'si oluşturur."""
+    progress_percent = min(max(round(progress_percent), 0), 100)  # %1 hassasiyet
+    return f"""
+    <div id="custom-progress" style="margin-top: 10px;">
+        <div style="font-size: 1rem; color: #C0C0C0; margin-bottom: 5px;" id="progress-label">{progress_label}</div>
+        <div style="width: 100%; background-color: #444; border-radius: 5px; overflow: hidden;">
+            <div id="progress-bar" style="width: {progress_percent}%; height: 20px; background-color: #6e8efb; transition: width 0.3s; max-width: 100%;"></div>
+        </div>
+    </div>
+    """
+
 def run_command_and_process_files(
     model_type,
     config_path,
@@ -141,8 +249,9 @@ def run_command_and_process_files(
         os.makedirs(OUTPUT_DIR, exist_ok=True)
 
         # Komut oluştur
+        INFERENCE_PATH = os.path.join(os.path.dirname(os.path.abspath(__file__)), "inference.py")
         cmd_parts = [
-            "python", "-m", "inference",
+            "python", INFERENCE_PATH,
             "--model_type", str(model_type),
             "--config_path", str(config_path),
             "--start_check_point", str(start_check_point),
@@ -188,7 +297,7 @@ def run_command_and_process_files(
                 stdout_output += line + "\n"
                 if i18n("loaded_audio").lower() in line.lower():
                     processed_files += 1
-                    progress_value = round((processed_files / total_files) * 80)
+                    progress_value = round(processed_files * base_progress_per_file)
                     if progress is not None and callable(getattr(progress, '__call__', None)):
                         progress(progress_value / 100, desc=i18n("running_separation").format(processed_files, total_files))
                         update_progress_html(i18n("running_separation").format(processed_files, total_files), progress_value)
@@ -217,7 +326,7 @@ def run_command_and_process_files(
         filename_model = extract_model_name_from_checkpoint(start_check_point)
         output_files = sorted(os.listdir(OUTPUT_DIR))
         if not output_files:
-            raise FileNotFoundError("No output files created in OUTPUT_DIR")
+            raise FileNotFoundError(i18n("no_output_files").format(OUTPUT_DIR))
 
         # Dosya yeniden adlandırma: 80-90%
         total_output_files = len(output_files)
@@ -248,7 +357,7 @@ def run_command_and_process_files(
 
         output_files = sorted(os.listdir(OUTPUT_DIR))
         if not output_files:
-            raise FileNotFoundError("No output files in OUTPUT_DIR after renaming")
+            raise FileNotFoundError(i18n("no_output_files_after_rename").format(OUTPUT_DIR))
 
         # Çıktıları eşleştir
         def find_file(keyword):
@@ -270,38 +379,47 @@ def run_command_and_process_files(
         for i, output_file in enumerate(output_list):
             if output_file and os.path.exists(output_file):
                 normalized_file = os.path.join(OUTPUT_DIR, f"{sanitize_filename(os.path.splitext(os.path.basename(output_file))[0])}.{output_format}")
-                if output_file.endswith(f".{output_format}") and output_file != normalized_file:
-                    shutil.copy(output_file, normalized_file)
-                elif output_file != normalized_file:
-                    audio, sr = librosa.load(output_file, sr=None, mono=False)
-                    sf.write(normalized_file, audio.T if audio.ndim > 1 else audio, sr)
-                else:
-                    normalized_file = output_file
-                normalized_outputs.append(normalized_file)
-
-                progress_value = round(90 + (i + 1) / len(output_list) * 5)
-                if progress is not None and callable(getattr(progress, '__call__', None)):
-                    progress(progress_value / 100, desc=f"Normalizing output {i+1}/{len(output_list)}")
-                    update_progress_html(f"Normalizing output {i+1}/{len(output_list)}", progress_value)
+                try:
+                    if output_file.endswith(f".{output_format}") and output_file != normalized_file:
+                        shutil.copy(output_file, normalized_file)
+                    elif output_file != normalized_file:
+                        audio, sr = librosa.load(output_file, sr=None, mono=False)
+                        sf.write(normalized_file, audio.T if audio.ndim > 1 else audio, sr)
+                    else:
+                        normalized_file = output_file
+                    normalized_outputs.append(normalized_file)
+
+                    progress_value = round(90 + (i + 1) / len(output_list) * 5)
+                    if progress is not None and callable(getattr(progress, '__call__', None)):
+                        progress(progress_value / 100, desc=i18n("normalizing_output").format(i + 1, len(output_list)))
+                        update_progress_html(i18n("normalizing_output").format(i + 1, len(output_list), progress_value))
+                except Exception as e:
+                    logging.error(f"Normalization failed for {output_file}: {e}")
+                    normalized_outputs.append(None)
             else:
                 normalized_outputs.append(None)
 
         # Apollo işlemi: 95-100%
         if use_apollo:
-            from apollo_processing import process_with_apollo  # Varsayılan modül
-            normalized_outputs = process_with_apollo(
-                output_files=normalized_outputs,
-                output_dir=OUTPUT_DIR,
-                apollo_chunk_size=apollo_chunk_size,
-                apollo_overlap=apollo_overlap,
-                apollo_method=apollo_method,
-                apollo_normal_model=apollo_normal_model,
-                apollo_midside_model=apollo_midside_model,
-                output_format=output_format,
-                progress=lambda p, desc: progress((95 + p * 5) / 100, desc=desc) if progress else None,
-                total_progress_start=95,
-                total_progress_end=100
-            )
+            try:
+                from apollo_processing import process_with_apollo
+                normalized_outputs = process_with_apollo(
+                    output_files=normalized_outputs,
+                    output_dir=OUTPUT_DIR,
+                    apollo_chunk_size=apollo_chunk_size,
+                    apollo_overlap=apollo_overlap,
+                    apollo_method=apollo_method,
+                    apollo_normal_model=apollo_normal_model,
+                    apollo_midside_model=apollo_midside_model,
+                    output_format=output_format,
+                    progress=lambda p, desc: progress((95 + p * 5) / 100, desc=desc) if progress else None,
+                    total_progress_start=95,
+                    total_progress_end=100
+                )
+            except ImportError:
+                logging.warning("apollo_processing module not found, skipping Apollo processing")
+            except Exception as e:
+                logging.error(f"Apollo processing failed: {e}")
 
         # Tamamlandı
         if progress is not None and callable(getattr(progress, '__call__', None)):
@@ -313,7 +431,6 @@ def run_command_and_process_files(
 
     except Exception as e:
         logging.error(f"run_command_and_process_files error: {str(e)}")
-        import traceback
         traceback.print_exc(file=sys.stderr)
         return (None,) * 14