Update app.py

app.py

@@ -51,6 +51,9 @@ processing_complete = False
 # Блокировка для доступа к movie_embeddings
 movie_embeddings_lock = threading.Lock()
 
+# Поток для обработки фильмов
+processing_thread = threading.Thread(target=process_movies)
+
 def process_movies():
     """
     Обрабатывает фильмы из очереди, создавая для них эмбеддинги.
@@ -60,10 +63,9 @@ def process_movies():
         try:
             movie = movies_queue.get(timeout=1)  # Тайм-аут 1 секунда
         except queue.Empty:
-            if processing_complete:
-                break
-            else:
-                continue
+            print("Очередь фильмов пуста.")
+            processing_complete = True
+            break
 
         title = movie["name"]
         print(f"Создается эмбеддинг для фильма '{title}'...")
@@ -175,15 +177,9 @@ iface = gr.Interface(
     ],
 )
 
-# Запускаем приложение
-iface.queue()
-iface.launch()
-
 # Запускаем поток для обработки фильмов
-processing_thread = threading.Thread(target=process_movies)
 processing_thread.start()
 
-# Устанавливаем флаг, что обработка завершена, когда поток завершается
-processing_thread.join()
-processing_complete = True
-print("Все фильмы обработаны.")
+# Запускаем приложение
+iface.queue()
+iface.launch()