From 3c3baa9093e2c3d833edd8b543d42f0bec52d603 Mon Sep 17 00:00:00 2001 From: m5l14i11 Date: Fri, 20 Sep 2024 00:53:33 +0300 Subject: [PATCH] upd --- core/events/ohlcv.py | 1 + feed/_historical.py | 6 +----- feed/_realtime.py | 6 +----- 3 files changed, 3 insertions(+), 10 deletions(-) diff --git a/core/events/ohlcv.py b/core/events/ohlcv.py index 8b69ab5a..6edc07a9 100644 --- a/core/events/ohlcv.py +++ b/core/events/ohlcv.py @@ -1,4 +1,5 @@ from dataclasses import dataclass, field + from core.models.entity.bar import Bar from core.models.symbol import Symbol from core.models.timeframe import Timeframe diff --git a/feed/_historical.py b/feed/_historical.py index 3506801d..6cde8328 100644 --- a/feed/_historical.py +++ b/feed/_historical.py @@ -122,11 +122,7 @@ async def _process_batch(self, batch: List[Bar]): async def _handle_market(self, batch: List[Bar]) -> None: for bar in batch: - await self.tell( - NewMarketDataReceived( - self.symbol, self.timeframe, bar - ) - ) + await self.tell(NewMarketDataReceived(self.symbol, self.timeframe, bar)) await asyncio.sleep(0.0001) async def _outbox(self, batch: List[Bar]) -> None: diff --git a/feed/_realtime.py b/feed/_realtime.py index 3ab4ef7c..6d22641d 100644 --- a/feed/_realtime.py +++ b/feed/_realtime.py @@ -99,8 +99,4 @@ async def _process_bars(self, bars: List[Bar]): logger.info(f"{self.symbol}_{self.timeframe}:{bar}") - await self.tell( - NewMarketDataReceived( - self.symbol, self.timeframe, bar - ) - ) + await self.tell(NewMarketDataReceived(self.symbol, self.timeframe, bar))