dev test

coldStartTasks/ai_pipeline/extract_video_best_frame.py

@@ -65,7 +65,7 @@ class ExtractVideoBestFrame:
         """
         fetch_query = f"""
             select count(1) as pool_size from {table_name}
-            where upload_status = 2 and file_state = 'PROCESSING';
+            where upload_status = 2 and file_state = 'PROCESSING' and extract_status = 0;
         """
         fetch_response = self.db_client.fetch(query=fetch_query, cursor_type=DictCursor)
         processing_task_pool_size = (