Fix DEBUG flag and TEMP_DIR path in EncodingConfig; enhance logging in FFmpegEncoder

video_encoder/config.py

@@ -10,8 +10,8 @@ import logging
 load_dotenv()
 
 class EncodingConfig:
-    DEBUG = os.getenv("DEBUG", "False") == "True"
-    TEMP_DIR = "./tmp"
+    DEBUG = os.getenv("DEBUG", "True") == "True"
+    TEMP_DIR = "/tmp"
     LOG_LEVEL = logging.DEBUG if DEBUG else logging.INFO
 
 logging.basicConfig(level=EncodingConfig.LOG_LEVEL)

video_encoder/worker/encoder.py

@@ -3,6 +3,9 @@ import os
 from pathlib import Path
 from typing import List, Dict
 from ..config import EncodingConfig
+import logging
+
+logger = logging.getLogger(__name__)
 
 class FFmpegEncoder:
     def __init__(self, input_path: str, output_dir: str):
@@ -39,25 +42,22 @@ class FFmpegEncoder:
             commands.append(cmd)
         return commands
 
-import logging
-logger = logging.getLogger(__name__)
-
-def encode(self) -> str:
-    """Execute encoding commands and return master playlist path"""
-    master_playlist = os.path.join(self.output_dir, f"{self.base_name}_master.m3u8")
+    def encode(self) -> str:
+        """Execute encoding commands and return master playlist path"""
+        master_playlist = os.path.join(self.output_dir, f"{self.base_name}_master.m3u8")
 
-    with open(master_playlist, "w") as f:
-        f.write("#EXTM3U\n")
-        for res in reversed(EncodingConfig.RESOLUTIONS):
-            f.write(f"#EXT-X-STREAM-INF:BANDWIDTH={res['video_bitrate'].replace('k', '000')},"
-                    f"RESOLUTION={res['width']}x{res['height']}\n")
-            f.write(f"{self.base_name}_{res['name']}.m3u8\n")
+        with open(master_playlist, "w") as f:
+            f.write("#EXTM3U\n")
+            for res in reversed(EncodingConfig.RESOLUTIONS):
+                f.write(f"#EXT-X-STREAM-INF:BANDWIDTH={res['video_bitrate'].replace('k', '000')},"
+                        f"RESOLUTION={res['width']}x{res['height']}\n")
+                f.write(f"{self.base_name}_{res['name']}.m3u8\n")
 
-    for cmd in self.generate_commands():
-        result = subprocess.run(cmd, capture_output=True)
-        logger.debug(f"FFmpeg command: {' '.join(cmd)}")
-        logger.debug(f"FFmpeg output: {result.stdout.decode()}")
-        logger.debug(f"FFmpeg error: {result.stderr.decode()}")
-        result.check_returncode()
+        for cmd in self.generate_commands():
+            result = subprocess.run(cmd, capture_output=True)
+            logger.debug(f"FFmpeg command: {' '.join(cmd)}")
+            logger.debug(f"FFmpeg output: {result.stdout.decode()}")
+            logger.debug(f"FFmpeg error: {result.stderr.decode()}")
+            result.check_returncode()
 
-    return master_playlist
+        return master_playlist