fix: bust cache when store has data so UI shows messages

app.py

@@ -260,6 +260,8 @@ def start_scraper(slot_idx: int, video_id: str, redis_key: str) -> None:
     _SCRAPER_STOP[key]    = stop_event
     _SCRAPER_THREADS[key] = t
     t.start()
+    # Clear the data cache so the UI picks up new messages immediately
+    load_stream_data.clear()
 
 
 def stop_scraper(slot_idx: int) -> None:
@@ -518,9 +520,10 @@ def csv_download(df_export, label, filename):
                        file_name=filename, mime="text/csv", key=filename)
 
 
-@st.cache_data(ttl=5, show_spinner=False)
-def load_stream_data(redis_key: str, limit: int | None = None):
-    """Load and parse messages from the in-memory store. Cached for 5s."""
+@st.cache_data(ttl=2, show_spinner=False)
+def load_stream_data(redis_key: str, _store_len: int = 0, limit: int | None = None):
+    """Load and parse messages from the in-memory store. Cached for 2s.
+    _store_len is used as a cache-busting parameter — changes when new data arrives."""
     if limit:
         raws = store_lrange(redis_key, -limit, -1)
     else:
@@ -888,7 +891,8 @@ st.divider()
 # ── DATA LOAD ─────────────────────────────────────────────────
 # Use stream A's redis_key (session state is the source of truth)
 _primary_key = st.session_state.streams[0]["redis_key"]
-all_data = load_stream_data(_primary_key)
+_current_len = store_llen(_primary_key)
+all_data = load_stream_data(_primary_key, _store_len=_current_len)
 data     = all_data[-msg_limit:] if len(all_data) > msg_limit else all_data
 
 if not all_data:
@@ -1410,7 +1414,7 @@ if len(active_streams) > 1:
             sidx   = st.session_state.streams.index(stream)
             color  = STREAM_COLORS[sidx]
             slabel = STREAM_NAMES[sidx]
-            s_data = load_stream_data(stream["redis_key"])
+            s_data = load_stream_data(stream["redis_key"], _store_len=store_llen(stream["redis_key"]))
             if not s_data:
                 col.info(f"No data yet for Stream {slabel}")
                 continue
@@ -1439,7 +1443,7 @@ if len(active_streams) > 1:
         sidx  = st.session_state.streams.index(stream)
         color = STREAM_COLORS[sidx]
         slabel = STREAM_NAMES[sidx]
-        s_data = load_stream_data(stream["redis_key"])
+        s_data = load_stream_data(stream["redis_key"], _store_len=store_llen(stream["redis_key"]))
         if not s_data:
             continue
         s_df = pd.DataFrame(s_data)