Update radio upload.

main.py

@@ -12,6 +12,7 @@ import pickle
 import re
 import sqlite3
 import time
+import traceback
 
 from google.auth.transport.requests import Request
 from google_auth_oauthlib.flow import InstalledAppFlow
@@ -355,8 +356,9 @@ async def message_callback(conn, cursor, youtube, client, room, event):
                         )
                     print(f"Added track to this week's playlist: {link}")
                     if recent:
-                        asyncio.create_task(process_radio_track(link, video_id, title))
+                        task = asyncio.create_task(process_radio_track(link, video_id, title))
-
+                        background_tasks.add(task)
+                        task.add_done_callback(background_tasks.discard)
 
 def in_playlist(cursor, video_id, playlist_id):
     """Checks if video is in playlist."""
@@ -444,7 +446,11 @@ async def backwards_sync(conn, cursor, youtube, client, room, start_token):
 
 async def process_radio_track(video_link, video_id, title):
     """Downloads native audio and pushes it to AzuraCast API in the background."""
+    try:
+        print(f"🚀 DEBUG: Background task started for {title}")
+
         if not AZURACAST_API_KEY:
+            print("❌ Error: AZURACAST_API_KEY is empty or missing.")
             return
 
         # Sanitize title for the local filesystem
@@ -454,7 +460,7 @@ async def process_radio_track(video_link, video_id, title):
 
         print(f"📻 Downloading audio for radio: {title}")
 
-    # 1. Download with yt-dlp (Keeping native AAC/Opus format)
+        # 1. Download with yt-dlp
         dl_cmd = [
             "yt-dlp",
             "--extract-audio",
@@ -464,11 +470,13 @@ async def process_radio_track(video_link, video_id, title):
         ]
 
         process = await asyncio.create_subprocess_exec(
-        *dl_cmd, stdout=asyncio.subprocess.DEVNULL, stderr=asyncio.subprocess.DEVNULL
+            *dl_cmd,
+            stdout=asyncio.subprocess.DEVNULL,
+            stderr=asyncio.subprocess.DEVNULL,
         )
         await process.communicate()
 
-    # Check for the file using glob since the extension (.m4a, .webm, .opus) is dynamic
+        # Check for the file using glob
         downloaded_files = glob.glob(f"{base_filepath}.*")
 
         if not downloaded_files:
@@ -497,7 +505,7 @@ async def process_radio_track(video_link, video_id, title):
         )
         stdout, _ = await curl_proc.communicate()
 
-    # 3. Extract unique_id and push to the live queue
+        # 3. Extract unique_id and queue
         try:
             response = json.loads(stdout.decode())
             unique_id = response.get("unique_id")
@@ -520,14 +528,17 @@ async def process_radio_track(video_link, video_id, title):
                 await req_proc.communicate()
                 print(f"✅ Queued on radio: {title}")
             else:
-            print(f"⚠️ Uploaded, but no unique_id returned. Response: {stdout.decode()}")
+                print(f"⚠️ Uploaded, but no unique_id returned: {stdout.decode()}")
         except json.JSONDecodeError:
             print(f"❌ Failed to parse AzuraCast response: {stdout.decode()}")
 
-    # Cleanup the local file so your container doesn't bloat
         if os.path.exists(filepath):
             os.remove(filepath)
 
+    except Exception as e:
+        print(f"💥 CRITICAL ERROR in background task: {e}")
+        traceback.print_exc()
+
 
 async def main():
     """Get DB and Matrix client ready, and start syncing."""
@@ -537,6 +548,7 @@ async def main():
     youtube = get_authenticated_service()
     client = await get_client(conn, cursor, youtube)
     sync_token = load_sync_token()
+    background_tasks = set()
 
     # This is incredibly dumb and most probably will exceed your YouTube API quota.
     if args.backwards_sync: