fix resources consumption

app/pages/05_Dashboard.py

@@ -28,7 +28,7 @@ from components.news import (
 )
 from utils.breaking_news_scorer import get_breaking_news_scorer
 from utils.ai_summary_store import init_storage, enqueue_items, fetch_summaries, get_status
-from utils.ai_summary_worker import start_worker_if_needed
+from utils.ai_summary_worker import start_worker_if_needed, is_worker_running
 
 # Import news scrapers
 try:
@@ -196,6 +196,17 @@ with st.sidebar:
     if auto_refresh:
         st.info("⏱️ Auto-refresh enabled (3 min)")
 
+    st.markdown("---")
+    st.markdown("### 🤖 AI Summary Worker")
+    worker_running = is_worker_running()
+    if worker_running:
+        st.success("● Worker running")
+    else:
+        st.warning("● Worker stopped")
+    if st.button("▶ Start Worker" if not worker_running else "↺ Restart Worker", use_container_width=True):
+        start_worker_if_needed()
+        st.rerun()
+
     st.markdown("---")
     st.markdown("### 📊 Feed Statistics")
 
@@ -280,9 +291,8 @@ with st.sidebar:
 # Check for forced refresh (don't clear yet - wait until after fetching)
 force_refresh = st.session_state.get('force_refresh', False)
 
-# Initialize AI summary store/worker (shared across sessions/processes)
+# Initialize AI summary store (shared across sessions/processes)
 init_storage()
-start_worker_if_needed()
 
 # Fetch news from all sources IN PARALLEL for maximum performance
 import pandas as pd
@@ -523,7 +533,7 @@ with st.spinner(f"Loading news from {_TOTAL_SOURCES} sources..."):
         with ThreadPoolExecutor(max_workers=4) as executor:
             futures_map = {executor.submit(fn): name for fn, name in _fetch_tasks}
             try:
-                for future in as_completed(futures_map, timeout=90):
+                for future in as_completed(futures_map, timeout=15):
                     source_name = futures_map[future]
                     try:
                         result, error = future.result()
@@ -535,7 +545,7 @@ with st.spinner(f"Loading news from {_TOTAL_SOURCES} sources..."):
                         completed_sources.append(f"{source_name} (error)")
                         status_placeholder.warning(f"⚠️ {source_name} failed, continuing with other sources...")
             except TimeoutError:
-                fetch_errors.append("⏱️ Some sources timed out after 90 seconds - displaying available results")
+                fetch_errors.append("⏱️ Some sources timed out after 15 seconds - displaying available results")
                 status_placeholder.warning(f"⚠️ {len(completed_sources)}/{_TOTAL_SOURCES} sources loaded (some timed out)")
                 all_sources = set(futures_map.values())
                 for source in all_sources - set(completed_sources):

app/utils/ai_summary_worker.py

@@ -87,15 +87,21 @@ def _pid_running(pid: int) -> bool:
         return False
 
 
+def is_worker_running() -> bool:
+    """Return True if the worker process is currently running."""
+    if not os.path.exists(PID_FILE):
+        return False
+    try:
+        with open(PID_FILE, "r", encoding="utf-8") as f:
+            pid = int(f.read().strip() or 0)
+        return bool(pid and _pid_running(pid))
+    except Exception:
+        return False
+
+
 def start_worker_if_needed():
-    if os.path.exists(PID_FILE):
-        try:
-            with open(PID_FILE, "r", encoding="utf-8") as f:
-                pid = int(f.read().strip() or 0)
-            if pid and _pid_running(pid):
-                return
-        except Exception:
-            pass
+    if is_worker_running():
+        return
 
     pid = os.fork()
     if pid != 0: