Update app.py

app.py

@@ -139,10 +139,45 @@ def clean_columns(df):
 # DOWNLOAD DATA
 # ============================================================
 
+# ============================================================
+# DOWNLOAD DATA WITH CACHE + RETRY
+# ============================================================
+
+LAST_DOWNLOAD = {}
+
+CACHE_SECONDS = 300
+
+
 def safe_download(symbol):
 
     try:
 
+        # ============================================
+        # CACHE
+        # ============================================
+
+        now = time.time()
+
+        csv_file = data_path(symbol)
+
+        if os.path.exists(csv_file):
+
+            last_time = LAST_DOWNLOAD.get(symbol, 0)
+
+            if now - last_time < CACHE_SECONDS:
+
+                df = pd.read_csv(
+                    csv_file,
+                    index_col=0,
+                    parse_dates=True
+                )
+
+                return df, True
+
+        # ============================================
+        # DOWNLOAD
+        # ============================================
+
         df = yf.download(
             symbol,
             period="90d",
@@ -156,10 +191,38 @@ def safe_download(symbol):
 
             df = clean_columns(df)
 
-            df.to_csv(data_path(symbol))
+            df.to_csv(csv_file)
+
+            LAST_DOWNLOAD[symbol] = now
 
             return df, True
 
+    except Exception as e:
+
+        logger.warning(
+            f"{symbol} download failed: {e}"
+        )
+
+    # ============================================
+    # FALLBACK TO CACHE
+    # ============================================
+
+    try:
+
+        if os.path.exists(csv_file):
+
+            logger.info(
+                f"Using cached data: {symbol}"
+            )
+
+            df = pd.read_csv(
+                csv_file,
+                index_col=0,
+                parse_dates=True
+            )
+
+            return df, False
+
     except Exception as e:
 
         logger.warning(e)
@@ -698,6 +761,7 @@ def realtime_scan():
 
     for symbol in SYMBOLS:
 
+            time.sleep(1)
         try:
 
             result = run_predict(symbol)
@@ -738,7 +802,7 @@ with gr.Blocks(
         interactive=False
     )
 
-    timer = gr.Timer(20)
+    timer = gr.Timer(120)
 
     timer.tick(
         fn=realtime_scan,