unstable fix

LoadBalancer.py

@@ -4,7 +4,6 @@ import re
 import urllib.parse
 from tvdb import fetch_and_cache_json
 from threading import Event, Thread
-from fastapi import BackgroundTasks
 import asyncio
 import time
 import logging
@@ -37,7 +36,7 @@ class LoadBalancer:
 
         # Initialize file structure and prefetching
         self.file_structure = indexer()
-        self.start_prefetching()
+        asyncio.run(self.start_prefetching())  # Run the async method directly
 
         # Start polling and file checking in separate threads
         polling_thread = Thread(target=self.start_polling)
@@ -49,13 +48,9 @@ class LoadBalancer:
         content_check_thread.daemon = True
         content_check_thread.start()
 
-    def start_prefetching(self):
-        """Start the metadata prefetching using FastAPI background tasks."""
-        # Create a FastAPI BackgroundTasks instance
-        background_tasks = BackgroundTasks()
-        # Add the prefetch_metadata coroutine to the background tasks
-        background_tasks.add_task(self.prefetch_metadata)
-        return background_tasks
+    async def start_prefetching(self):
+        """Start the metadata prefetching."""
+        await self.prefetch_metadata()
 
     async def prefetch_metadata(self):
         """Prefetch metadata for all items in the file structure."""
@@ -95,10 +90,8 @@ class LoadBalancer:
             time.sleep(120)  # Wait for 2 minutes
             current_file_structure = indexer()
             if current_file_structure != self.previous_file_structure:
-                # Trigger prefetching using FastAPI background tasks
-                background_tasks = self.start_prefetching()
-                # Here you need to integrate background_tasks with FastAPI
-                # For example, you might need to pass it to your FastAPI route handler or another component
+                # Trigger prefetching directly in an asyncio context
+                asyncio.run(self.start_prefetching())
                 self.previous_file_structure = current_file_structure
             else:
                 logging.info("No new content detected.")