selected videos added

src/automation.py

@@ -386,14 +386,14 @@ class ContentAutomation:
 
             self.data_holder.visual_assets["all_videos"] = [
                 {
-                    "url": row.get("video_filename", "").strip(),
+                    "url": row.get("VIDEO_FILENAME", "").strip(),
                     "local_path": VideoDownloader().download_video(
-                        video_filename=row.get("video_filename", "").strip(),
+                        video_filename=row.get("VIDEO_FILENAME", "").strip(),
                         download_path=download_path
                     )
                 }
                 for _, row in self.asset_selector.video_library.iterrows()
-                if row.get("video_filename", "").strip() in allowed_videos
+                if row.get("VIDEO_FILENAME", "").strip() in allowed_videos
             ]
         else:
             self.data_holder.visual_assets["all_videos"] = [

src/video_downloader.py

@@ -567,7 +567,7 @@ class VideoDownloader:
         results = []
         
         for video in self.video_library:
-            filename = video.get('video_filename', '').lower()
+            filename = video.get('VIDEO_FILENAME', '').lower()
             short_desc = video.get('short_description', '').lower()
             desc = video.get('description', '').lower()
             
@@ -585,7 +585,7 @@ def add_folder_name_column(input_csv, output_csv, downloader):
         with open(output_csv, newline="", encoding="utf-8") as f:
             reader = csv.DictReader(f)
             for row in reader:
-                processed.add(row["video_filename"])
+                processed.add(row["VIDEO_FILENAME"])
 
     with open(input_csv, newline="", encoding="utf-8") as infile, \
          open(output_csv, "a", newline="", encoding="utf-8") as outfile:
@@ -598,7 +598,7 @@ def add_folder_name_column(input_csv, output_csv, downloader):
             writer.writerow(["folder_name"] + reader.fieldnames)
 
         for row in reader:
-            video_filename = row["video_filename"]
+            video_filename = row["VIDEO_FILENAME"]
 
             # Skip if already processed
             if video_filename in processed:
@@ -622,9 +622,9 @@ def add_link_column(input_csv, output_csv, downloader):
     if os.path.exists(output_csv):
         with open(output_csv, newline="", encoding="utf-8") as f:
             reader = csv.DictReader(f)
-            if reader.fieldnames and "video_filename" in reader.fieldnames:
+            if reader.fieldnames and "VIDEO_FILENAME" in reader.fieldnames:
                 for row in reader:
-                    processed.add(row["video_filename"].split("/")[-1])
+                    processed.add(row["VIDEO_FILENAME"].split("/")[-1])
 
     # 2. Process the files
     with open(input_csv, newline="", encoding="utf-8") as infile:
@@ -642,7 +642,7 @@ def add_link_column(input_csv, output_csv, downloader):
                 writer.writeheader()
 
             for row in reader:
-                video_filename = row["video_filename"].split("/")[-1]
+                video_filename = row["VIDEO_FILENAME"].split("/")[-1]
 
                 if video_filename in processed:
                     continue
@@ -715,7 +715,7 @@ if __name__ == "__main__":
         # # Write CSV
         # with open(output_csv, "w", newline="", encoding="utf-8") as f:
         #     writer = csv.writer(f)
-        #     writer.writerow(["video_filename"])
+        #     writer.writerow(["VIDEO_FILENAME"])
         #     writer.writerows(rows)
 
         # print(f"CSV created with {len(rows)} entries → {output_csv}")

video_analyser/modules/csv_writer.py

@@ -17,7 +17,7 @@ class CSVWriter:
     
     # Exact column order as specified
     COLUMNS = [
-        'video_filename',
+        'VIDEO_FILENAME',
         'category',
         'duration_seconds',
         'short_description',
@@ -113,7 +113,7 @@ class CSVWriter:
             assert isinstance(row['final_selection_score'], int)
             
             # String fields
-            assert isinstance(row['video_filename'], str)
+            assert isinstance(row['VIDEO_FILENAME'], str)
             assert isinstance(row['category'], str)
             assert isinstance(row['short_description'], str)
             assert isinstance(row['description'], str)
@@ -148,7 +148,7 @@ class CSVWriter:
         
         # Prepare row data
         row = {
-            'video_filename': os.path.basename(video_path),
+            'VIDEO_FILENAME': os.path.basename(video_path),
             'category': ai_analysis.get('category', 'uncategorized'),
             'duration_seconds': technical_analysis['duration_seconds'],
             'short_description': ai_analysis.get('short_description', ''),