Update app.py

app.py

@@ -131,8 +131,11 @@ async def fetch_ohlcv(session, tools, symbol, timeframe, exchange, total):
     while got < total:
         oldest = frames[-1]["ts"].iloc[0]
         end_ms = int((oldest - epoch) // pd.Timedelta("1ms")) - 1
-        res = await call_tool(session, tools, "get_ohlcv", symbol=symbol, timeframe=timeframe,
-                              exchange=exchange, limit=page, until=end_ms)
+        try:
+            res = await call_tool(session, tools, "get_ohlcv", symbol=symbol, timeframe=timeframe,
+                                  exchange=exchange, limit=page, until=end_ms)
+        except Exception:  # noqa: BLE001  (ör. Connection closed) -> eldeki sayfalarla devam
+            break
         if res is None or (isinstance(res, dict) and "error" in res):
             break
         try:
@@ -302,32 +305,44 @@ IND_NAMES = [
 ]
 
 
-async def fetch_indicators(session, tools, symbol, timeframe, exchange, limit):
-    """Önce hepsini tek çağrıda dener; geçersiz ad yüzünden hata olursa her göstergeyi ayrı çağırıp çalışanları toplar."""
-    if "compute_indicators" not in tools:
-        return None
+IND_CHUNK = 6
+
+
+async def fetch_indicators(symbol, timeframe, exchange, limit):
+    """Göstergeleri KÜÇÜK PARÇALAR halinde (her parça birkaç gösterge), ana oturumdan AYRI bir Tickscope sürecinde çeker.
+    Bir parça sunucuyu çökertirse ("Connection closed") yeni süreç açılır, o parçanın adları atlanır, kalanlarla devam edilir."""
+    out = {"by_indicator": {}, "failed": [], "mode": "chunked", "reconnects": 0, "last_error": None}
     kw = dict(symbol=symbol, timeframe=timeframe, exchange=exchange, limit=limit, include_series=True)
-    out = {"by_indicator": {}, "failed": [], "mode": None}
-    try:
-        res = await call_tool(session, tools, "compute_indicators", indicators=IND_NAMES, **kw)
-    except Exception:  # noqa: BLE001
-        res = None
-    if isinstance(res, dict) and "error" not in res and extract_series(res, 0):
-        out["by_indicator"]["batch"] = res
-        out["mode"] = "batch"
-        return out
-    out["mode"] = "single"
-    out["batch_error"] = _strip_series(res) if isinstance(res, dict) else None
-    for name in IND_NAMES:
+    chunks = [IND_NAMES[i:i + IND_CHUNK] for i in range(0, len(IND_NAMES), IND_CHUNK)]
+    i = 0
+    while i < len(chunks):
         try:
-            r = await call_tool(session, tools, "compute_indicators", indicators=[name], **kw)
-        except Exception:  # noqa: BLE001
-            out["failed"].append(name)
-            continue
-        if r is None or (isinstance(r, dict) and "error" in r):
-            out["failed"].append(name)
-            continue
-        out["by_indicator"][name] = r
+            async with stdio_client(SERVER) as (r, w):
+                async with ClientSession(r, w) as session:
+                    await session.initialize()
+                    tools = {t.name: t for t in (await session.list_tools()).tools}
+                    if "compute_indicators" not in tools:
+                        return None
+                    while i < len(chunks):
+                        names = chunks[i]
+                        res = await call_tool(session, tools, "compute_indicators", indicators=names, **kw)
+                        if isinstance(res, dict) and "error" not in res and extract_series(res, 0):
+                            out["by_indicator"][f"c{i}"] = res
+                        else:       # parçada geçersiz ad var: tek tek dene
+                            for name in names:
+                                r1 = await call_tool(session, tools, "compute_indicators", indicators=[name], **kw)
+                                if r1 is None or (isinstance(r1, dict) and "error" in r1):
+                                    out["failed"].append(name)
+                                else:
+                                    out["by_indicator"][name] = r1
+                        i += 1
+        except Exception as e:  # noqa: BLE001
+            out["reconnects"] += 1
+            out["last_error"] = _root(e)
+            out["failed"] += [n for n in chunks[i] if n not in out["by_indicator"]]   # çökertene dokunma, atla
+            i += 1
+            if out["reconnects"] > 6:
+                break
     return out
 
 
@@ -800,6 +815,7 @@ def predict(df: pd.DataFrame, horizon: int, fee: float = 0.0006, n_folds: int =
 
 # ----------------------------------------------------------------- Ana akış
 async def run_async(symbol, timeframe, exchange, horizon, limit):
+    extra = {}
     async with stdio_client(SERVER) as (r, w):
         async with ClientSession(r, w) as session:
             await session.initialize()
@@ -811,13 +827,13 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
             if isinstance(ohlcv, dict) and "error" in ohlcv:
                 raise RuntimeError(ohlcv["error"])
 
-            # Tickscope'un kendi analizleri (opsiyonel, hata verirse atla)
-            deep = await call_tool(session, tools, "deep_analyze", symbol=symbol,
-                                   timeframe=timeframe, exchange=exchange)
-            ind = await fetch_indicators(session, tools, symbol, timeframe, exchange, int(limit))
-
-            # Tickscope'un diğer tüm analiz/piyasa araçları (canlı bağlam; şema uyuşmazsa hata olarak kaydedilir)
-            extra = {}
+            # Buradan sonrası opsiyonel: sunucu çökse bile elimizdeki mum verisiyle devam edilir
+            deep = None
+            try:
+                deep = await call_tool(session, tools, "deep_analyze", symbol=symbol,
+                                       timeframe=timeframe, exchange=exchange)
+            except Exception as e:  # noqa: BLE001
+                extra["deep_analyze_error"] = _root(e)
             for name in EXTRA_TOOLS:
                 if name not in tools:
                     continue
@@ -830,11 +846,19 @@ async def run_async(symbol, timeframe, exchange, horizon, limit):
             ci = tools.get("compute_indicators")
             if ci is not None:   # gerçek gösterge adlarını görebilmek için araç açıklaması
                 extra["_compute_indicators_description"] = (getattr(ci, "description", "") or "")[:4000]
-            if isinstance(ind, dict):
-                ser = extract_series(ind, 0)
-                extra["_ts_diag"] = {"mod": ind.get("mode"), "seri_sayisi": len(ser),
-                                     "seri_uzunluklari": sorted({len(v) for v in ser.values()})[:10],
-                                     "calismayan_adlar": ind.get("failed")}
+
+    # Göstergeler: ayrı Tickscope süreçleri (ana oturum kapandıktan sonra; DuckDB kilidi çakışmasın)
+    ind = None
+    try:
+        ind = await fetch_indicators(symbol, timeframe, exchange, int(limit))
+    except Exception as e:  # noqa: BLE001
+        extra["indicators_error"] = _root(e)
+    if isinstance(ind, dict):
+        ser = extract_series(ind, 0)
+        extra["_ts_diag"] = {"seri_sayisi": len(ser),
+                             "seri_uzunluklari": sorted({len(v) for v in ser.values()})[:10],
+                             "yeniden_baglanma": ind.get("reconnects"), "son_hata": ind.get("last_error"),
+                             "calismayan_adlar": ind.get("failed")}
     return ohlcv, deep, ind, extra
 
 
@@ -861,7 +885,13 @@ def run(symbol, timeframe, exchange, horizon, limit, use_deriv=True, max_feat=40
     except BaseException as e:  # noqa: BLE001
         import traceback
         traceback.print_exc()
-        return f"**Hata:** {_root(e)}", None, ""
+        msg = _root(e)
+        hint = ""
+        if "closed" in msg.lower():
+            hint = ("\n\nMCP süreci kapandı. Terminaldeki Tickscope/uvx hata çıktısına bakın; "
+                    "ayrıca aynı anda açık başka bir Tickscope süreci DuckDB kilidini tutuyor olabilir "
+                    "(eski `uvx tickscope-mcp` süreçlerini kapatıp tekrar deneyin).")
+        return f"**Hata:** {msg}{hint}", None, ""
 
     p, thr, bt = res["p_up"], res["thr"], res["bt"]
     signal = "LONG" if p > thr else "SHORT" if p < 1 - thr else "NÖTR"
@@ -953,4 +983,3 @@ with gr.Blocks(title="Tickscope Tahmin") as demo:
 
 if __name__ == "__main__":
     demo.launch()
-