lulu/arbitrage-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: deduplicate recent_large_trades to prevent memory bloat

Browse Source 
Each evaluate cycle was re-appending all qualifying trades from
win_fast, causing duplicates. Added seen-set dedup.
This commit is contained in:
root 2026-03-01 07:58:51 +00:00
parent 8b73500d22
commit 9528d69a42
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/signal_engine.py
View File

@ -261,9 +261,12 @@ class SymbolState:
cutoff = now_ms - 15 * 60 * 1000 cutoff = now_ms - 15 * 60 * 1000
while self.recent_large_trades and self.recent_large_trades[0][0] < cutoff: while self.recent_large_trades and self.recent_large_trades[0][0] < cutoff:
self.recent_large_trades.popleft() self.recent_large_trades.popleft()
# 只检查新trade（避免重复添加）
seen = set(t[0] for t in self.recent_large_trades) # time_ms作为去重key
for t in self.win_fast.trades: for t in self.win_fast.trades:
if t[1] >= p99 and t[0] > cutoff: if t[1] >= p99 and t[0] > cutoff and t[0] not in seen:
self.recent_large_trades.append((t[0], t[1], t[3])) self.recent_large_trades.append((t[0], t[1], t[3]))
seen.add(t[0])
def evaluate_signal(self, now_ms: int) -> dict: def evaluate_signal(self, now_ms: int) -> dict:
cvd_fast = self.win_fast.cvd cvd_fast = self.win_fast.cvd