fix: remove cache from load_stream_data so in-memory store is always read fresh

app.py

@@ -260,8 +260,6 @@ 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:
@@ -520,10 +518,8 @@ def csv_download(df_export, label, filename):
                        file_name=filename, mime="text/csv", key=filename)
 
 
-@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."""
+def load_stream_data(redis_key: str, limit: int | None = None):
+    """Load and parse messages from the in-memory store (no cache — store is in-memory)."""
     if limit:
         raws = store_lrange(redis_key, -limit, -1)
     else:
@@ -892,7 +888,7 @@ st.divider()
 # Use stream A's redis_key (session state is the source of truth)
 _primary_key = st.session_state.streams[0]["redis_key"]
 _current_len = store_llen(_primary_key)
-all_data = load_stream_data(_primary_key, _store_len=_current_len)
+all_data = load_stream_data(_primary_key)
 data     = all_data[-msg_limit:] if len(all_data) > msg_limit else all_data
 
 if not all_data:
@@ -1414,7 +1410,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"], _store_len=store_llen(stream["redis_key"]))
+            s_data = load_stream_data(stream["redis_key"])
             if not s_data:
                 col.info(f"No data yet for Stream {slabel}")
                 continue
@@ -1443,7 +1439,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"], _store_len=store_llen(stream["redis_key"]))
+        s_data = load_stream_data(stream["redis_key"])
         if not s_data:
             continue
         s_df = pd.DataFrame(s_data)