0.0.2.5 V Beta

LoadBalancer.py

@@ -1,7 +1,7 @@
 import os
-import requests
 import json
 import urllib.request
+import concurrent.futures
 from tqdm import tqdm
 from indexer import indexer
 import re
@@ -9,7 +9,7 @@ from tvdb import fetch_and_cache_json
 from threading import Event
 import time
 import logging
-from threading import Thread, Event, Timer
+from threading import Thread, Event
 from api import InstancesAPI
 
 
@@ -18,8 +18,8 @@ CACHE_DIR = os.getenv("CACHE_DIR")
 download_progress = {}
 
 class LoadBalancer:
-    def __init__(self, cache_dir, index_file, token, repo, polling_interval=1, max_retries=3, initial_delay=1):
-        self.version = "0.0.2.4 V Beta"
+    def __init__(self, cache_dir, index_file, token, repo, polling_interval=2, max_retries=3, initial_delay=1):
+        self.version = "0.0.2.5 V Beta"
         self.instances = []
         self.instances_health = {}
         self.polling_interval = polling_interval
@@ -78,7 +78,7 @@ class LoadBalancer:
         
     def get_reports(self):
         reports = self.instances_api.fetch_reports()
-        
+
         # Initialize temporary JSON data holders
         temp_film_store = {}
         temp_tv_store = {}
@@ -92,9 +92,10 @@ class LoadBalancer:
                 logging.error(f"Failed to get report from {instance_url}. Removing instance.")
                 self.remove_instance(instance_url)
 
-        # Compare and update actual JSON files after processing all reports
-        self.update_film_store_json(temp_film_store) 
-        self.update_tv_store_json(temp_tv_store)
+        # Use concurrent.futures to update JSON files in separate threads without waiting
+        with concurrent.futures.ThreadPoolExecutor() as executor:
+            executor.submit(self.update_film_store_json, temp_film_store)
+            executor.submit(self.update_tv_store_json, temp_tv_store)
 
     def process_report(self, instance_url, report, temp_film_store, temp_tv_store):
         film_store = report.get('film_store', {})