upd

risk/_actor.py

@@ -50,7 +50,7 @@ def __init__(
         super().__init__(symbol, timeframe)
         self.lock = asyncio.Lock()
         self._position = (None, None)
-        self._ohlcv = deque(maxlen=55)
+        self._ohlcv = deque(maxlen=233)
         self.config = config_service.get("position")
 
     def pre_receive(self, event: RiskEvent):
@@ -95,6 +95,9 @@ async def _close_position(self, event: PositionClosed):
                 None if event.position.side == PositionSide.SHORT else short_position,
             )
 
+            if not long_position and not short_position:
+                self._ohlcv.clear()
+
     async def _handle_market_risk(self, event: NewMarketDataReceived):
         async with self.lock:
             self._ohlcv.append(event.ohlcv)