unstable fix 2

LoadBalancer.py

@@ -34,9 +34,8 @@ class LoadBalancer:
         if not os.path.exists(self.CACHE_DIR):
             os.makedirs(self.CACHE_DIR)
 
-        # Initialize file structure and prefetching
+        # Initialize file structure
         self.file_structure = indexer()
-        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)
@@ -90,8 +89,8 @@ class LoadBalancer:
             time.sleep(120)  # Wait for 2 minutes
             current_file_structure = indexer()
             if current_file_structure != self.previous_file_structure:
-                # Trigger prefetching directly in an asyncio context
-                asyncio.run(self.start_prefetching())
+                # Schedule the prefetching task
+                asyncio.get_event_loop().create_task(self.start_prefetching())
                 self.previous_file_structure = current_file_structure
             else:
                 logging.info("No new content detected.")