refactor: Standardize imports to use src as the root package.

src/a2e_avatar.py

@@ -8,7 +8,7 @@ import time
 from dataclasses import dataclass
 from enum import Enum
 import os
-from utils import logger
+from src.utils import logger
 from google_src import ai_studio_sdk
 import json_repair
 from src.config import get_config_value, set_config_value

src/asset_manager/asset_downloader.py

@@ -9,7 +9,7 @@ from pathlib import Path
 from typing import Dict, List, Optional, Any
 from urllib.parse import urlparse
 
-from utils import logger, is_valid_video, resize_video, remove_black_padding
+from src.utils import logger, is_valid_video, resize_video, remove_black_padding
 from file_downloader import get_file_downloader
 from src.config import get_config_value
 from .video_lib import get_video_lib, VideoLib

src/asset_manager/asset_processor.py

@@ -11,7 +11,7 @@ import pandas as pd
 import json_repair
 from moviepy.editor import VideoFileClip
 from google_src import ai_studio_sdk
-from utils import logger
+from src.utils import logger
 from src.config import get_config_value
 from .video_lib import get_video_lib
 

src/asset_manager/audio_lib.py

@@ -7,7 +7,7 @@ import re
 import pandas as pd
 from typing import Optional, List
 
-from utils import logger, clean_and_drop_empty
+from src.utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
 from src.config import get_config_value

src/asset_manager/content_strategy_lib.py

@@ -6,7 +6,7 @@ import os
 import pandas as pd
 from typing import Optional, List
 
-from utils import logger, clean_and_drop_empty
+from src.utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
 from src.config import get_config_value

src/asset_manager/text_overlay_lib.py

@@ -6,7 +6,7 @@ import os
 import pandas as pd
 from typing import Optional
 
-from utils import logger, clean_and_drop_empty
+from src.utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
 from src.config import get_config_value

src/asset_manager/video_lib.py

@@ -6,7 +6,7 @@ import os
 import pandas as pd
 from typing import Optional, List, Dict
 
-from utils import logger, clean_and_drop_empty
+from src.utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
 from src.config import get_config_value

src/cleanup_manager.py

@@ -2,7 +2,7 @@ import os
 import shutil
 from datetime import datetime
 from src.config import get_config_value
-from utils import logger
+from src.utils import logger
 from google_src.google_sheet import GoogleSheetReader
 from google_src.gcs_utils import delete_gcs_file
 from google_src.drive_utils import delete_file_from_drive

src/execution_tracker.py

@@ -1,7 +1,7 @@
 from datetime import datetime
 from src.config import get_config_value
 from google_src.google_sheet import GoogleSheetReader
-from utils import logger
+from src.utils import logger
 
 def load_executed_from_gsheet(setup_type=None, job_index=None):
     """Load executed scripts from Google Sheets logs.

src/google_src/ai_studio_sdk.py

@@ -4,7 +4,7 @@ from google.genai import types
 import uuid
 import time
 from src.utils import logger
-import utils
+import src.utils as utils
 from src.config import get_config_value
 
 def _get_request_id() -> str:

src/main.py

@@ -8,7 +8,7 @@ sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
 from src.config import get_config_value, configure_job_environment
 from pipeline_processor import download_all_library_videos
 from google_src.gcs_utils import list_gcs_files
-from workflows import run_content_strategy_workflow, run_plain_video_workflow
+from src.workflows import run_content_strategy_workflow, run_plain_video_workflow
 
 def pre_check():
     """Validate required environment variables defined in video_generate.env."""

src/pipeline_processor.py

@@ -1,9 +1,9 @@
 import os
 import asyncio
-from utils import logger, clean_tts_script
+from src.utils import logger, clean_tts_script
 from src.config import get_config_value, set_config_value
-from pipelines.factory import get_automation_pipeline
-from asset_manager import get_asset_downloader
+from src.pipelines.factory import get_automation_pipeline
+from src.asset_manager import get_asset_downloader
 from google_src.gcs_utils import list_gcs_files
 import hashlib
 

src/pipelines/__init__.py

@@ -18,7 +18,7 @@ from pipelines.standard_ai_pipeline import StandardAIPipeline
 from pipelines.avatar_ai_pipeline import AvatarAIPipeline
 from pipelines.hard_cut_pipeline import HardCutPipeline
 from pipelines.beats_cut_pipeline import BeatsCutPipeline
-from pipelines.factory import get_automation_pipeline
+from src.pipelines.factory import get_automation_pipeline
 
 __all__ = [
     "ContentAutomationBase",

src/pipelines/ai_pipeline.py

@@ -4,12 +4,12 @@ from typing import Dict, Any, Optional
 from moviepy.editor import AudioFileClip
 from abc import abstractmethod
 
-from utils import logger
+from src.utils import logger
 from src.config import get_config_value, set_config_value
 from google_src.gcs_utils import upload_file_to_gcs
 from video_generation_process import generate_video_process
 from google_src import ai_studio_sdk
-from pipelines.base import ContentAutomationBase
+from src.pipelines.base import ContentAutomationBase
 
 class AIContentAutomationBase(ContentAutomationBase):
     """

src/pipelines/avatar_ai_pipeline.py

@@ -1,7 +1,7 @@
 from moviepy.editor import AudioFileClip
-from utils import logger
+from src.utils import logger
 from src.config import get_config_value, set_config_value
-from pipelines.ai_pipeline import AIContentAutomationBase
+from src.pipelines.ai_pipeline import AIContentAutomationBase
 from a2e_avatar import create_greenscreen_video_workflow
 
 class AvatarAIPipeline(AIContentAutomationBase):

src/pipelines/base.py

@@ -3,15 +3,15 @@ import asyncio
 from abc import ABC, abstractmethod
 from typing import Dict, Any, Optional
 
-from utils import logger
-import utils
+from src.utils import logger
+import src.utils as utils
 from src.config import get_config_value, set_config_value
 from google_src.gcs_utils import upload_file_to_gcs
-from video_renderer import VideoRenderer
+from src.video_renderer import VideoRenderer
 from google_src.tts import GoogleTTS
 from google_src.stt import GoogleSTT
 from file_downloader import get_file_downloader
-from asset_manager import get_asset_downloader, get_audio_lib, AssetProcessor, get_text_overlay_lib
+from src.asset_manager import get_asset_downloader, get_audio_lib, AssetProcessor, get_text_overlay_lib
 from video_editor import loudness_normalize, remove_green_bg
 from video_editor.onscreen_cta import add_cta
 from google_src.ai_studio_sdk import generate

src/pipelines/beats_cut_pipeline.py

@@ -1,9 +1,9 @@
 from typing import Dict, Any
 from moviepy.editor import AudioFileClip
-from utils import logger
+from src.utils import logger
 import utils
 from src.config import get_config_value
-from pipelines.non_ai_pipeline import NonAIContentAutomationBase
+from src.pipelines.non_ai_pipeline import NonAIContentAutomationBase
 
 class BeatsCutPipeline(NonAIContentAutomationBase):
     async def determine_video_parameters(self) -> Dict[str, Any]:

src/pipelines/factory.py

@@ -1,9 +1,9 @@
 from src.config import get_config_value
-from pipelines.base import ContentAutomationBase
-from pipelines.standard_ai_pipeline import StandardAIPipeline
-from pipelines.avatar_ai_pipeline import AvatarAIPipeline
-from pipelines.hard_cut_pipeline import HardCutPipeline
-from pipelines.beats_cut_pipeline import BeatsCutPipeline
+from src.pipelines.base import ContentAutomationBase
+from src.pipelines.standard_ai_pipeline import StandardAIPipeline
+from src.pipelines.avatar_ai_pipeline import AvatarAIPipeline
+from src.pipelines.hard_cut_pipeline import HardCutPipeline
+from src.pipelines.beats_cut_pipeline import BeatsCutPipeline
 
 def get_automation_pipeline() -> ContentAutomationBase:
     """

src/pipelines/hard_cut_pipeline.py

@@ -1,8 +1,8 @@
 from typing import Dict, Any
 from moviepy.editor import AudioFileClip
-from utils import logger
+from src.utils import logger
 from src.config import get_config_value
-from pipelines.non_ai_pipeline import NonAIContentAutomationBase
+from src.pipelines.non_ai_pipeline import NonAIContentAutomationBase
 
 class HardCutPipeline(NonAIContentAutomationBase):
     async def determine_video_parameters(self) -> Dict[str, Any]:

src/pipelines/non_ai_pipeline.py

@@ -5,10 +5,10 @@ from typing import Dict, Any, List
 from moviepy.editor import AudioFileClip
 from abc import abstractmethod
 
-from utils import logger
-import utils
+from src.utils import logger
+import src.utils as utils
 from src.config import get_config_value, set_config_value
-from pipelines.base import ContentAutomationBase
+from src.pipelines.base import ContentAutomationBase
 
 class NonAIContentAutomationBase(ContentAutomationBase):
     """

src/pipelines/standard_ai_pipeline.py

@@ -1,6 +1,6 @@
-from utils import logger
+from src.utils import logger
 from src.config import get_config_value, set_config_value
-from pipelines.ai_pipeline import AIContentAutomationBase
+from src.pipelines.ai_pipeline import AIContentAutomationBase
 
 class StandardAIPipeline(AIContentAutomationBase):
     """

src/video_editor/loudness_normalize.py

@@ -2,7 +2,7 @@ import subprocess
 import json
 import re
 from pathlib import Path
-from utils import logger
+from src.utils import logger
 
 
 def normalize_loudness(

src/video_editor/onscreen_cta.py

@@ -5,7 +5,7 @@ import numpy as np
 import re
 from video_editor.safe_zone import SafeZone
 import uuid
-from utils import logger
+from src.utils import logger
 
 def get_emoji_unicode(emoji_char):
     """Convert emoji character to unicode hex string (e.g., '1f6cd')"""

src/video_editor/text_clip.py

@@ -11,7 +11,7 @@ from PIL import Image, ImageDraw, ImageFont, ImageFilter
 import numpy as np
 from video_editor.safe_zone import SafeZone
 import cv2
-from utils import logger
+from src.utils import logger
 import math
 
 # --- Constants ---

src/video_generation_process.py

@@ -9,7 +9,7 @@ from typing import Dict, Optional
 from src.config import get_config_value
 from google_src import ai_studio_sdk
 from runwayml.generate_video import generate_video_runway
-from utils import logger
+from src.utils import logger
 from google_src.gcs_utils import upload_file_to_gcs
 
 async def generate_video_process(prompt: str, duration: int, image_input: str = None) -> Dict:

src/video_renderer.py

@@ -23,7 +23,7 @@ from moviepy.editor import (
     vfx
 )
 import textwrap
-from utils import logger, reverse_clip as utils_reverse_clip, get_temp_dir
+from src.utils import logger, reverse_clip as utils_reverse_clip, get_temp_dir
 import time
 from video_editor.text_clip import create as create_text_clip, group_words_by_time_and_width, caption_style_1, caption_style_2, caption_style_3, caption_style_4, caption_style_on_screen_text, caption_style_on_screen_text_top
 import subprocess

src/workflows/content_strategy_workflow.py

@@ -2,9 +2,9 @@ import os
 from execution_tracker import load_executed_from_gsheet, log_progress_to_gsheet
 from pipeline_processor import process_single_row, configure_row_settings
 from cleanup_manager import process_delete_entries
-from asset_manager import get_content_strategy_lib
+from src.asset_manager import get_content_strategy_lib
 from src.config import get_config_value, set_config_value
-from utils import logger
+from src.utils import logger
 
 async def run_content_strategy_workflow(commit=False, job_index=None, total_jobs=None):
     """Process content strategies from Google Sheet with progress tracking."""

src/workflows/plain_video_workflow.py

@@ -3,7 +3,7 @@ from execution_tracker import load_executed_from_gsheet, log_progress_to_gsheet
 from pipeline_processor import process_single_row, configure_row_settings
 from cleanup_manager import process_delete_entries
 from src.config import get_config_value
-from utils import logger
+from src.utils import logger
 
 async def run_plain_video_workflow(commit=False, job_index=None, total_jobs=None):
     """Generate plain videos (music-synced, no AI content) with progress tracking."""